博客首页 → RabbitMQ

最新文章列表

RabbitMQ使用场景练习：Validated User ID、Length Limit(十二 )

Validated User ID 发送消息时指定userid，只有是当前conn的用户名才可以发送出去消息(测试发现非当前conn用户名，队列没有也没有创建，可能因为是在同一个channel)。用于消费者consumer需要知道消息是从哪个用户发过来的情况 package com.demo.mq.rabbitmq.example12; import java.io.IOException; ...
RabbitMQ 
sheungxin 评论(0) 有1390人浏览 2016-12-16 15:14

RabbitMQ使用场景练习：消息确认机制(十一)

消息确认机制 RabbitMQ提供了transaction、confirm两种消息确认机制。transaction即事务机制，手动提交和回滚；confirm机制提供了Confirmlistener和waitForConfirms两种方式。confirm机制效率明显会高于transaction机制，但后者的优势在于强一致性。如果没有特别的要求，建议使用conrim机制。 1、从实验来看，消息的确认机 ...
javaRabbitMQ 
sheungxin 评论(0) 有5689人浏览 2016-12-16 12:08

rabbitmq添加用户失败

rabbitmq 添加用户时报如下错误 Error description:   {could_not_start,rabbit,       {notsup,           [{crypto,sha256,1,[{file,"crypto.erl"},{line,857}]},            {rabbit_password,hash,2,          ...
rabbitmq添加用户 
ywu 评论(0) 有4176人浏览 2016-12-15 21:29

RabbitMQ使用场景练习：优先级队列(十)

优先级队列      只有当消费者不足，不能及时进行消费的情况下，优先级队列才会生效      RabbitMQ3.5以后已经集成了rabbitmq_priority_queue 引用http://www.rabbitmq.com/community-plugins.html 验证方式：触发为及时消费场景，常用场景与Qos结合使用 1、可先发送消息，再进行消费 2、开启手动应答、设置Qos。若为 ...
javaRabbitMQ 
sheungxin 评论(0) 有3635人浏览 2016-12-14 16:05

RabbitMQ使用场景练习：监听器Listener(九)

监听器      RabbitMQ中监听器有ReturnListener、ConfirmListener、ShutdownListener，本练习中使用ReturnListener，在发布消息时设置mandatory等于true，监听消息是否有相匹配的队列，没有时ReturnListener将执行handleReturn方法，消息将返给发送者      设置mandatory=true，当路由不到队 ...
RabbitMQjava 
sheungxin 评论(0) 有8057人浏览 2016-12-13 21:23

RabbitMQ使用场景练习：延迟队列(八)

延时队列      在实际业务场景中可能会用到延时消息发送，例如支付场景，准时支付、超过未支付将执行不同的方案，其中超时未支付可以看做一个 ...
RabbitMQjava 
sheungxin 评论(0) 有5860人浏览 2016-12-13 17:42

RabbitMQ使用总结：持久化

持久化      RabbitMQ的持久化是为了实现服务从异常状态恢复后恢复之前的状态。RabbitMQ发送消息涉及交换器(exchange)、队列(queue)、消息，因而持久化包 ...
RabbitMQ 
sheungxin 评论(0) 有2039人浏览 2016-12-13 10:29

RabbitMQ使用场景练习：RPC(七)

RPC，同步消息      RabbitMQ默认的consumer为异步监听，RPC应用需要实现consumer的同步，可以使用QueueingConsumer(继承与DefaultConsumer，定义了一个堵塞队列LinkedBlockingQueue)实现同步      实际上就是服务端、客户端各定义一个消息队列，相互发送消息，客户端发送消息后同步等待结果返回 注意要点 发送消息时指定回 ...
javaRabbitMQ 
sheungxin 评论(0) 有2652人浏览 2016-12-08 17:51

RabbitMQ使用场景练习：Headers(六)

Headers转发器      消息发送时可以在header中定义一些键值对，接收消息队列与headers转发器绑定时可以指定键值对，all、any两种方式(队列绑定转发器时指定的键值对与headers中存储的键值对匹配)，匹配上即可接收到消息 注意要点 headers转发器：//声明headers转发器 channel.exchangeDeclare("header_exchan ...
javaRabbitMQ 
sheungxin 评论(0) 有3056人浏览 2016-12-08 15:28

RabbitMQ使用场景练习：主题Topic(五)

主题转发器(Topic)      Topic转发器的功效包含fanout、direct类型的转发器，其特殊的地方在于转发器与队列的绑定时routingkey可以使用通配符*、#，使用*就相当于fanout，不使用通配符就相当于direct，否则就是模糊匹配，匹配上的队列都可以收到消息 注意要点 topic转发器：channel.exchangeDeclare("topic_logs ...
javaRabbitMQ 
sheungxin 评论(0) 有2444人浏览 2016-12-06 17:26

RabbitMQ使用场景练习：路由选择Routing(四)

路由选择(Routing)      Routing即按照某条路线把消息发送出去，所有这条路线上的队列都将接收到消息。      使用direct转发器，在转发器上使用同一routingkey绑定多个队列，根据routingkey发送消息，所有绑定的队列都将收到消息 注意要点 direct转发器，把消息直接转发到绑定routingkey的队列：channel.exchangeDeclare(& ...
javaRabbitMQ 
sheungxin 评论(0) 有831人浏览 2016-12-06 17:02

RabbitMQ使用场景练习：发布/订阅(三)

发布/订阅      即实现单点发送消息，多点接收。使用fanout转发器，广播到所有它知道的队列上 注意要点 fanout转发器中不需要routingKey，指定也无效 创建fanout转发器：channel.exchangeDeclare("fanout_logs", "fanout"); channel.basicPublish("f ...
javaRabbitMQ 
sheungxin 评论(0) 有1288人浏览 2016-12-05 17:30

RabbitMQ使用场景练习：工作队列(二)

工作队列      工作队列的好处在于多个工作线程共享执行任务队列，使用round-robin的方式分发任务（简单的理解：依次把任务分配给工作进程，一次性分配1..n个任务，平均分配）。 注意要点 工作线程的产生，在同一队列上声明多个Consumer：channel.basicConsume(queue, false, consumer); 消息持久化：//第二个参数durable设为true ...
javaRabbitMQ 
sheungxin 评论(0) 有1189人浏览 2016-12-05 17:11

RabbitMQ使用场景练习：入门实例(一)

注意要点 同一队列多次创建：//此处声明队列为了防止接收者先运行，队列还不存在时创建队列(同一队列只会创建一次) channel.queueDeclare(queue, false, false, false, null); 消息发送类 package com.demo.mq.rabbitmq.example01; import java.io.IOException; imp ...
RabbitMQjava 
sheungxin 评论(0) 有1682人浏览 2016-12-05 16:20

RabbitMQ的管理与监控

开启management plugin功能 1、management plugin默认安装未开启，需要执行以下命令：    $ cd /usr/lib/rabbitmq/bin/    $ sudo rabbitmq-plugins enable rabbitmq_management 2、management plugin提供HTTP API来管理和监控RabbitMQ Server，具体包含如 ...
RabbitMQ 
sheungxin 评论(0) 有1628人浏览 2016-11-30 17:08

RabbitMQ的安装

1、RabbitMQ安装 官网下载地址：http://www.rabbitmq.com/download.html 引用RabbitMq、ActiveMq、ZeroMq、kafka之间的比较,资料汇总： http://blog.csdn.net/linsongbin1/article/details/47781187 https://my.oschina.net/u/236698/blog/501 ...
erlangubuntuRabbitMQ 
sheungxin 评论(0) 有803人浏览 2016-11-30 16:02

RabbitMQ安装与配置

一、安装Rabbit MQ   1. 下载并安装Erlang：http://www.erlang.org/downloads 2. 下载并安装Rabbit MQ：http://www.rabbitmq.com/releases/rabbitmq-server/       默认安装的Rabbit MQ 监听端口是15672   二、Rabbit MQ配置和运行   1. 激活管 ...
RabbitMQ消息mq异步 
拓子轩 评论(0) 有5776人浏览 2016-11-14 15:38

rabbitmq简介、安装及集成springboot

点击链接：http://mp.weixin.qq.com/s?__biz=MzIxMzY1NTM3Nw==&mid=2247483697&idx=1&sn=5df33ca85b9c643fc518a4418400b225&chksm=97b2cb0fa0c542198e236c315f8487a47d983e2a2d90752acfb0a681e89a7bb9c14e ...
rabbitmq 
IT小将 评论(0) 有1317人浏览 2016-11-13 23:30

rabbitmq实现高吞吐量的rpc调用

rabbitmq实现rpc调用基本思路： 客户端（client）：客户端发起rpc调用，这当成一个消息，发送到rabbitmq服务器。这个消息会携带两个特殊（额外）的信息，一个是调用序号，一个是回调队列名称。调用序号需要服务端原样返回，而回调队列名称是用于服务端将结果放入这个队列中，以便客户端取回结果。 服务端（service）：服务端接收到了一个rpc调用后，执行调用代码，将结果返回到指定的回调队 ...
rpc架构rabbitmq 
我的网络世界 评论(0) 有9311人浏览 2016-10-09 16:21

rabbitmq 消息重新入队

basicRecover：是路由不成功的消息可以使用recovery重新发送到队列中。   basicReject：是接收端告诉服务器这个消息我拒绝接收,不处理,可以设置是否放回到队列中还是丢掉，而且只能一次拒绝一个消息,官网中有明确说明不能批量拒绝消息，为解决批量拒绝消息才有了basicNack。   basicNack：可以一次拒绝N条消息，客户端可以设置basicNack方法的mu ...
rabbitmq消息拒绝重新入队处理 
zhongmin2012 评论(0) 有1193人浏览 2016-08-01 14:46

最近博客热门TAG

Java(141746) C(73651) C++(68608) SQL(64571) C#(59609) XML(59133) HTML(59043) JavaScript(54918) .net(54785) Web(54513) 工作(54116) Linux(50906) Oracle(49876) 应用服务器(43288) Spring(40812) 编程(39454) Windows(39381) JSP(37542) MySQL(37268) 数据结构(36423)

博客人气排行榜

    博客电子书下载排行

      >>浏览更多下载

      相关资讯

      相关讨论

      Global site tag (gtag.js) - Google Analytics