代码实现:发送消息---》接受消息---》服务器配置
//1 发送消息(接受回复消息)
public class SenderMessageService {
//发布指定消息到指定地址(在发布之前,建议将消息保存到数据库)
public void publish(String type, Object object) {
try {
InitialContext init...
分类:
其他好文 时间:
2015-08-19 20:42:27
阅读次数:
221
ActiveMQ是JMS规范的一个实现产品,即对JMS的一套接口进行了实现。所以下面我们先对JMS与ActiveMQ进行一个简单介绍,然后再介绍ActiveMQ的P2P与PubSub两种开发模式。
一、 JMS简介
JMS即Java消息服务,是J2EE的13规范之一,是一套面向消息中间件(MOM)的应用程序接口。用在两个程序之间,或分布式系统中发送消息,进行...
分类:
其他好文 时间:
2015-08-19 13:26:47
阅读次数:
183
RocketMQ 源码分析RocketMQ 的设计思想来自于Kafka,在具体设计时体现了自己的选择和需求,具体差别可以看RocketMQ与Kafka对比(18项差异)。接下来记录下自己阅读源码的一些探索。
RocketMQ的整体架构如下,可以看到各个组件充当的角色,Name Server 负责维护一些全局的路由信息:当前有哪些broker,每个Topic在哪个broker上等; Broker具体处...
分类:
其他好文 时间:
2015-08-01 23:37:44
阅读次数:
754
消息中间件(message orientedmiddleware)是指支持与保障分布式应用程序之间同步/异步收发消息的中间件。消息是分布式应用之间进行数据交换的基本信息单位,分布式应用程序之间的通信接口由消息中间件提供。其中,异步方式指消息发送方在发送消息时不必知道接收方的状态,更无需等待接收方的回...
分类:
其他好文 时间:
2015-08-01 11:23:39
阅读次数:
265
ActiveMQ 是Apache出品,最流行的,能力强劲的开源消息总线。ActiveMQ 是一个完全支持JMS1.1和J2EE 1.4规范的 JMSProvider实现。
MQ英文名Message Queue,我们习惯称其为消息队列,是消息的接受和转发的容器,可用于消息推送。
安装
在官网下载,我下载的是apache-activemq-5.11.1版本。解压后...
分类:
其他好文 时间:
2015-07-31 16:26:16
阅读次数:
123
现实的企业中,对于消息通信的应用一直都非常的火热,而且在J2EE的企业应用中扮演着特殊的角色,所以对于它研究是非常有必要的。...
分类:
其他好文 时间:
2015-07-31 01:25:34
阅读次数:
129
ZeroMQ——一个轻量级的消息通信组件ZeroMQ是一个轻量级的消息通信组件,尽管名字中包含了"MQ",严格上来讲ZeroMQ并不是"消息队列/消息中间件"。ZeroMQ是一个传输层API库, 更关注消息的传输。与消息队列相比,ZeroMQ有以下一些特点:点对点无中间节点传统的消息队列都需要一个消...
1什么是RabbitMQ?RabbitMQ是实现AMQP(高级消息队列协议)的消息中间件的一种,最初起源于金融系统,用于在分布式系统中存储转发消息,在易用性、扩展性、高可用性等方面表现不俗。消息中间件主要用于组件之间的解耦,消息的发送者无需知道消息使用者的存在,反之亦然:单向解耦双向解耦(如:RPC...
分类:
其他好文 时间:
2015-07-20 19:14:59
阅读次数:
110
安装Mavenhttp://maven.apache.org/download.cgi (apache-maven-3.3.3-bin.zip)安装步骤:《Maven的安装、配置及使用入门》http://www.cnblogs.com/dcba1112/archive/2011/05/01/2033...
分类:
其他好文 时间:
2015-07-18 10:47:46
阅读次数:
308
【https://github.com/alibaba/RocketMQ/wiki/rmq_vs_kafka】淘宝内部的交易系统使用了淘宝自主研发的Notify消息中间件,使用Mysql作为消息存储媒介,可完全水平扩容,为了进一步降低成本,我们认为存储部分可以进一步优化,2011年初,Linkin开...
分类:
其他好文 时间:
2015-07-17 15:34:48
阅读次数:
127