rabbit mq 与JMS
MQ的消费-生产者模型的一个典型的代表,一端往消息队列中不断的写入消息,而另一端则可以读取或者订阅队列中的消息。MQ和JMS类似,但不同的是JMS是SUN JAVA消息中间件服务的一个标准和API定义,而MQ则是遵循了AMQP协议的具体实现和产品。
MQ 有很多产品:IBM的,rabbitmq, activemq 等。
这里介绍的rabbitmq 只支持点对点的方式。所以没有完全实现JMS的标准,所以说它不是一个JMS产品,而rabitmq 和Jobss JMS 它们实现了JMS的各项标准,是开源的JMS产品。
rabbitmq 的特点我简的理解有如下方面:支持集群,速度和性能可能会高于其他MQ产品。而且听朋友们提到rabbitmq 不会丢失消息,稳定性要好。还有一个优点为是消息的消费者可以时间无关。
缺点是他本身只支持点对点的消费方式,没有实现JMS标准,在功能上不会有那么强大。好在它提供接了一些监听接口,我们实现这些接口能满足应用对消息的基本需求。
这里介绍rabbitmq环境找寻和接发消息。
(一)官方网站:[url]http://www.rabbitmq.com, [/url]了解一个技术的最好方式是去他的官方网站。
(二)rabbitmq 服务器环境搭建
rabbitmq的服务器因操作系统不同有多个版本。这里以XP为例。请见
http://www.rabbitmq.com/install-windows.html所需要下载的软件Erlang和rabbitmqserver都可以在该地址下载.
先下载安装Erlang,并将erlang bin目录加至PATH
Firstly, download and run the Erlang Windows Binary File. It takes around 5 minutes.
再下载安装rabbintmq server.
second download and run rabbitmq-server-2.8.4.exe
最后启动 rabbitmq_server-2.8.4\sbin\rabbitmq-server.bat
以上就是rabbitmq的服务器搭建过程.
(三)消息发送和接收:
rabbintmq 支持如下:请见
http://www.rabbitmq.com/getstarted.htmlC# (using .net/c# client)
erlang (using erlang client)
java (using java client)
perl (using Net::RabbitFoot)
php (using a fork of php-amqplib)
python (using pika)
python-puka (using puka)
ruby (using amqp gem)
下载java客户端:
发送消息代码这里就不写了。因为在官方网站上已经提供代码:请见:
http://www.rabbitmq.com/getstarted.html这里举了六个例子。主要是描述RabbitMQ 的两大核心组件是 Exchange 和 Queue的特点
分享到:
相关推荐
spring-boot-mq-rabbitmq 一套打通rabbitmq 打开可用 有注释 妈妈再也不用担心你的rabbitmq不会了
rabbitmq3-management 为镜像名称
目前流程的消息队列主要有:ActivityMQ/kafka/redis/rabbitmq等。通过对这些MQ进行比较分析rabbitmq优势:1.从社区活跃度;2.持久化消息比较(ZeroMq 不支持,ActiveMq 和RabbitMq 都支持。持久化消息主要是指我们...
beego环境下 rabbitmq封装以及使用
flink-sql集成rabbitmq
Rabbit MQ 是建立在强大的Erlang OTP平台上,因此安装Rabbit MQ的前提是安装Erlang
rabbitmq3.8 windows64位安装包 包含erlang22打包一起下载!!!!!!!!!!!!!
MQClient用于与RabbitMQ的一个消息客户端转发程序,他负责监听RabbitMQ中的队列,并即时获取队列消息,按照配置进行转发消息。对消息处理结果监控,提供失败多次重试、失败邮件、转发失败队列等功能。
该RabbitMQ客户端是以QAMPQ为基础进行创建的测试工程,可直接编译通过,在各配置项中添加有详细备注,以方便理解该工程结构,也可以此工程结构进行RabbitMQ的Qt语言的相关项目开发。
消息队列(MQ)之RabbitMQ
主要用于调试RabbitMQ,进行压力测试等,一个非常好用的工具
用户操作日志对于每一个系统来说是不可或缺的,并且操作日志应该单独抽取为一个模块业务,不应该与主业务系统之间耦合在一起。 故而我们需要将其单独抽出并以异步的方式与主模块进行异步通信交互数据。 要求:采用...
比较MQ产品之RabbitMQ与Kafka.zip
RabbitMQClientUtil是MQ的测试工具类,他封装了fanout、direct、topic三种exchange模式,并包括发送数据和接收数据。 Test1、Test2是测试类 使用maven管理,在pom.xml文件中引入如下代码: <!-- Rabbitmq工具包...
jmeter测试Rabbitmq的方法 AMQP Publisher/Consumer 请求 介绍 Exchange(交换机):如果此处不填写,使用默认名称--(AMQP default) Exchange Type:分别是direct(单播),fanout(广播),topic(组播),headers,每种类型...
封装了RabbitMQ的订阅者线程和发布者线程(还有个初始化工厂的连接工具类),另外附加一个安卓的使用demo
tp6使用rabbitmq
采用python编写的批量删除rabbitmq的队列或交换机。 1.修改rabbitmq_delete.py中rabbitmq的配置; 2.执行以下命令: 删除队列: python3 rabbitmq_delete.py -k ‘udata.climb’ -d 1 删除交换机: python3 rabbitmq_...
rabbitmq 3.9.3 配置文件
RabbitMq与Spring整合实例,整个工程采用maven,具体过程看博文: http://blog.csdn.net/evankaka/article/details/50495437