这两天温故了python的multiprocessing多进程模块,看到的pipe和queue这两种ipc方式,啥事ipc?ipc就是进程间的通信模式,常用的一半是socke,rpc,pipe和消息队列等。今个就再把pipe和queue搞搞。#coding:utf-8
importmultiprocessing
importtime
defproc1(pipe):
whileTrue:
..
分类:
编程语言 时间:
2014-09-08 03:16:16
阅读次数:
421
学习云风的skynet源代码,简单记录下。void skynet_globalmq_push(struct message_queue * queue) { struct global_queue *q= Q; uint32_t tail = GP(__sync_fetch_and_add(&q->...
分类:
Web程序 时间:
2014-09-06 17:24:23
阅读次数:
228
1:简要说明 MQ全称为Message Queue,消息队列(MQ)是一种应用程序对应用程序的通信方法。应用程序通过读写出入队列的消息(针对应用程序的数据)来通信,而无需专用连接来链接它们。消 息传递指的是程序之间通过在消息中发送数据进行通信,而不是通过直接调用彼此来通信,直接调用通常是用于诸如.....
分类:
编程语言 时间:
2014-09-05 15:46:31
阅读次数:
187
redis支持发布、订阅的功能,基本的命令有publish、subscribe等。在jedis中,有对应的java方法,并且只能发布字符串消息。为了传输对象,需要将对象进行序列化,并封装成字符串进行处理。将对象序列化后,只能成为字节流,如何封装成字符串是一个难点。...
分类:
其他好文 时间:
2014-09-04 17:08:49
阅读次数:
264
许多朋友都不会使用MSDNLIBRARY(虽然MSDN跟MSDNLIBRARY不是一回事,但是下文中还是简写为MSDN),其实它是非常重要的东西。其实所有的说明都可以在MSDN中查到。环境:VS2008+SP1补丁MSDNLIBRARY2008+SP1补丁打开这个版本的MSDN后,可以看到如图的界面在最左下角,我们可以看到Co..
安装后检查1. 确保服务正常运行首先查看服务的运行状态: #service xxx status为防止对子服务有疏漏,可使用ps + grep 查看: # ps aux |grep xx2. 确保服务连接上消息队列查看相关日志。如nova的日志默认存在于/var/log/nova下。3. 确保各项服...
分类:
其他好文 时间:
2014-09-03 09:33:06
阅读次数:
183
好久没有写了,最近项目用到RabbitMQ,找了一些资料试验,最后终于成功了,把安装配置的步骤分享给大家。一、Erlang安装具体过程:1.双击otp_win32_R16801.exe(不同版本可能命名字不一样),选择next2.默认安装在C盘,建议程序安装在非系统盘比如D盘(如果安装在C盘可能会出...
分类:
其他好文 时间:
2014-09-02 19:31:45
阅读次数:
466
UCOS中的消息队列并不是真正意义上的队列,它只是发送了想要发送数据的指针,这个时候,如果发送多个同一个变量的不同数据,那么数据就相当于被覆盖了.解决办法: 定义一个缓存数组buffer[i]; 更改变量i的数值,就可以实现一个变相的FIFO,因为每次发送的变量的指针是不同的. i++; i...
分类:
其他好文 时间:
2014-09-01 10:40:52
阅读次数:
182
1. 概述Posix IPC 包括:Posix消息队列、Posix信号量、Posix共享内存区Posix IPC在访问它们的函数和描述它们的信息上有一些类似点。本章讲述所有这些共同属性:用于标识的路径名、打开或创建时指定的标志、访问权限。Posix IPC 函数汇总2. IPC名字三种类型的Posi...
分类:
其他好文 时间:
2014-09-01 01:37:50
阅读次数:
342
1. 概述三种类型的System V IPC:System V 消息队列、System V 信号量、System V 共享内存区System V IPC在访问它们的函数和内核为它们维护的信息上共享许多类似点。本章讲述所有这些共同属性。下图汇总了所有System V IPC 函数2. key_t键、f...
分类:
其他好文 时间:
2014-09-01 01:37:22
阅读次数:
172