rabbitmq学习9:使用spring-amqp发送消息及同步接收消息 通过对spring-amqp看重要类的认识,下面来通过spring-amqp的发送消息及同步接收消息是如何实现的。有兴趣的朋友 可以去spring-amqp官网下载例子。 先来看看HelloWorldConfigu...
分类:
其他好文 时间:
2015-01-07 23:25:38
阅读次数:
123
引言: 消息系统是互联网公司在应对大流量、高负载系统中非常常用的一种系统通信机制,它除了可以将不同系统解耦,还可以实现不同的多点系统之间的同步或异步通信机制,它的高性能、高扩展性以及稳定性,一直为各大公司所广泛采用,并且各个互联网公司都开发了各自的分布式消息系统,比如阿里、360、京东等等。本文将基于开源的rabbitMq为例,来介绍其安装和部署的基本过程。...
分类:
其他好文 时间:
2015-01-07 20:57:50
阅读次数:
209
1:发送Uri uri = new Uri("amqp://10.0.4.85:5672/"); ConnectionFactory factory = new ConnectionFactory(); factory.UserName = "abc"; ...
分类:
其他好文 时间:
2015-01-07 14:38:44
阅读次数:
155
准备开始 高级消息队列协议(AMQP1)是一个异步消息传递所使用的应用层协议规范。作为线路层协议,而不是API(例如JMS2),AMQP客户端能够无视消息的来源任意发送和接受信息。现在,已经有相当一部分不同平台的服...
分类:
其他好文 时间:
2015-01-07 13:22:49
阅读次数:
340
在云计算环境中,很多时候需要用它其他机器的计算资源,我们有可能会在接收到Message进行处理时,会把一部分计算任务分配到其他节点来完成。那么,RabbitMQ如何使用RPC呢?在本篇文章中,我们将会通过其它节点求来斐波纳契完成示例。1. 客户端接口 Client interface 为了展示一个R...
分类:
其他好文 时间:
2015-01-06 15:30:25
阅读次数:
161
在上篇文章RabbitMQ消息队列(五):Routing 消息路由 中,我们实现了一个简单的日志系统。Consumer可以监听不同severity(严重级别)的log。但是,这也是它之所以叫做简单日志系统的原因,因为是仅仅能够通过severity(严重级别)设定。不支持更多的标准。 比如syslog...
分类:
其他好文 时间:
2015-01-06 15:28:42
阅读次数:
135
上一篇文章使用的是Direct的Exchange,但是没有指定Queue的名字,这样只能是先运行Consumer之后,Producer在运行发消息Consumer才能收到,否则先运行Producer发送消息,在运行Consumer是收不到之前Producer发送的消息,因为Queue的名字像是这样的...
分类:
其他好文 时间:
2015-01-06 15:21:53
阅读次数:
166
什么是ProtoBuf? 一种轻便高效的结构化数据存储格式,可以用于结构化数据串行化,或者说序列化。它很适合做数据存储或 RPC 数据交换格式。可用于通讯协议、数据存储等领域的语言无关、平台无关、可扩展的序列化结构数据格式。目前提供了 C++、Java、Python 三种语言的 API。 它可以作为...
分类:
其他好文 时间:
2015-01-06 15:19:30
阅读次数:
107