涉及网络传输的应用,序列化不可避免。发送端以某种规则将消息转成byte数组进行发送。
接收端则以约定的规则进行byte[]数组的解析。
序列化的选择可以是jdk序列化,hessian,jackson,protobuf等。
其中jdk序列化的缺点是性能及要求发送方与接收方都是java应用。
hessia,protobuf等都是基于压缩重复字段的思想,减少传输数据量以提高性能。
ja...
分类:
其他好文 时间:
2015-06-24 19:02:07
阅读次数:
857
storm中只能进行任务计算,不能保存中间结果,最后结果。这就有一个需求,保存计算结果,最好还是分布式的,因为storm也是分布式,大数据计算。流行的分布式计算中使用队列保存数据居多。kafka适合大量写入,但是稳定性差,项目采用的是rabbitmq.rabiitmq有2种模式:1.集群模式(高稳定...
分类:
其他好文 时间:
2015-06-23 19:48:21
阅读次数:
213
阅读erlang一些开源web框架RabbitMQ、Ranch,他们使用多个进程在同一时间accept一socket。以这样的方式,使socketport监控共享很多其他的机会调度工作,但,在erlang在,socket接受一个新的连接之后,假设有一个过程,你要处理的消息,调用gen_tcp:con...
分类:
其他好文 时间:
2015-06-19 14:51:34
阅读次数:
268
转自http://www.diggerplus.org/archives/3110引言你是否遇到过两个(多个)系统间需要通过定时任务来同步某些数据?你是否在为异构系统的不同进程间相互调用、通讯的问题而苦恼、挣扎?如果是,那么恭喜你,消息服务让你可以很轻松地解决这些问题。消息服务擅长于解决多系统、异构...
分类:
其他好文 时间:
2015-06-17 12:59:28
阅读次数:
100
AMQP server on c
ontroller:5672 is unreachable: [Errno 113] EHOSTUNREACH. Trying again in 2 seconds....
分类:
其他好文 时间:
2015-06-15 22:13:27
阅读次数:
2073
#运行各示例脚本 [1]1. 下载各语言的示例代码 https://github.com/rabbitmq/rabbitmq-tutorials2. 安装pip,命令"yum -y install python-pip"。3. 安装pika(版本0.9.5),命令"pip install pika=...
分类:
其他好文 时间:
2015-06-15 12:36:40
阅读次数:
105
远程过程调用(RPC) (使用 pika 0.9.8 Python客户端) 在第二篇教程中,我们学习了如何使用工作队列在多个workers之间分发耗时的任务。 但是假使我们需要在一台远程的计算机上执行一个函数并等待结果呢?那就将是...
分类:
其他好文 时间:
2015-06-14 07:06:43
阅读次数:
534
一、None of the specified endpoints were reachable这个异常在创建连接时抛出(CreateConnection()),原因一般是ConnectionFactory参数设置不对,比如HostName、UserName、Password标准设置:var fac...
分类:
其他好文 时间:
2015-06-13 11:14:03
阅读次数:
243
?路由 (使用 pika 0.9.8 Python客户端) 在前一篇教程中,我们构建了一个简单的logging系统。我们可以将log消息广播给许多接收者。 在这篇教程中,我们将给它添加一个功能 - 我们将使它能够只订阅消息的一个子集...
分类:
其他好文 时间:
2015-06-11 09:40:29
阅读次数:
158
原创文章转载请注明出处:@协思, http://zeeman.cnblogs.com网上一些安装教程都较为繁琐,实际上只需要两个RPM包,几分钟即可完成一台实例部署。准备下载Erlang包: http://www.rabbitmq.com/releases/erlang/下载RabbitMQ:htt...
分类:
其他好文 时间:
2015-06-10 18:50:29
阅读次数:
122