rabbitmq简单实例

落日映苍穹つ 2022-03-15 15:15 328阅读 0赞

# [rabbitmq简单实例][rabbitmq] #

JMS组件：activemq（慢）  
AMQP组件（advance message queue protocol）：rabbitmq和kafka

一.、消息队列解决了什么问题？  
异步处理  
应用解耦  
流量削锋  
日志处理

二、rabbitmq安装与配置

三、java操作rabbitmq  
1. simple 简单队列   
2. work queues 工作队列 公平分发 轮询分发  
3. publish/subscribe 发布于订阅  
4. routing 路由选择 通配符模式  
5. topics 主题  
6. 手动和自动确认消息  
7. 队列的持久化和非持久化  
8. rabbitmq的延迟队列

四、spring AMQP spring-rabbitmq

五、场景demo mq实现搜索引擎DIH增量

六、场景demo 未支付订单30分钟，取消

七、大数据应用 类似百度统计 cnzz架构 消息队列

**一、简单队列**

ConnectionUtils.java

![ContractedBlock.gif][]

Send.java

![ContractedBlock.gif][]

Receive.java

![ContractedBlock.gif][]

**二、工作队列**

**2.1 轮询分发**

Send.java

![ContractedBlock.gif][]

Receive1.java

![ContractedBlock.gif][]

Receive2.java

![ContractedBlock.gif][]

现象：消费者1和消费者2处理的消息是一样的

消费者1偶数

消费者1奇数

这种方式叫做轮询分发（round-robin）,结果就是不管谁忙活着谁清闲，都不会多给一个消息，任意消息总是你一个，我一个

**2.2 公平分发（fair dipatch）**

Send.java

![ContractedBlock.gif][]

Receive1.java

![ContractedBlock.gif][]

Receive2.java

![ContractedBlock.gif][]

现象：消费者2处理的消息比消费者1多，能者多劳

**三、消息与应答ack与消息持久化durable**

boolean autoAck = false;

channel.basicConsume(QUEUE\_NAME, autoAck, consumer);

boolean autoAck = true;(自动确认模式)一旦rabbitmq将消息分发给消费者，就会从内存中删除

这种情况下，如果杀死正在执行的消费者，就会丢失正在处理的消息

boolnea autoAck = false;(手动模式)，如果有一个消费者挂掉，就会交付给其他消费者，

rabbitmq支持消息应答，消费者发送一个应答，告诉rabbitmq这个消息我已经处理完成，你可以删除了，然后rabbitmq就删除

内存中的消息

消息应答模式是打开的，false

Message acknowkedgment

消息持久化

boolean durable = false
    channel.queueDeclare(QUEUE_NAME, durable, false, false, null);

[rabbitmq]: https://www.cnblogs.com/cxxjohnson/p/9101454.html
[ContractedBlock.gif]: /images/20220315/b0546b85b8364849b3b5c699afaaad9b.png

发表评论取消回复

表情：

评论列表（有 0 条评论，328人围观）

还没有评论，来说两句吧...

相关阅读

相关简单讲解RabbitMQ

[简单讲解RabbitMQ][RabbitMQ] [RabbitMQ应用][RabbitMQ 1] -------------------- 文章目录

Bertha 。/ 2023年09月28日 11:51/ 0 赞/ 118 阅读

相关【RabbitMQ】-RabbitMQ安装及简单操作

前言 RabbitMQ安装简单操作： -------------------- 安装注意事项： ![在这里插入图片描述][watermark_type_ZmFu

迈不过友情╰/ 2022年12月26日 11:11/ 0 赞/ 178 阅读

相关 SpringBoot-RabbitMq 简单实例

添加maven依赖： <dependency> <groupId>org.springframework.boot</groupId> <

以你之姓@/ 2022年06月09日 12:55/ 0 赞/ 162 阅读

相关 rabbitMQ(二) java简单使用rabbitMQ

前言：在这里我将用java来简单的实现rabbitMQ。下面我们带着下面问题来一步步的了解和学习rabbitMQ。 1：如果消费者连接中断，这期间我们应该怎么办 2：如何做

亦凉/ 2022年06月02日 05:08/ 0 赞/ 311 阅读

相关 RabbitMQ入门实例

一、基本概念理解 producer：消息的生产者 consumer：消息的消费者 virtual host：虚拟主机（对RabbitMQ进行功能性设置：

港控/mmm°/ 2022年05月28日 08:57/ 0 赞/ 184 阅读

相关 rabbitMQ教程 spring整合rabbitMQ代码实例

转载自 [https://www.cnblogs.com/tohxyblog/p/7256554.html][https_www.cnblogs.com_tohxyblog_p

叁歲伎倆/ 2022年05月16日 10:09/ 0 赞/ 234 阅读

相关 rabbitmq简单实例

[rabbitmq简单实例][rabbitmq] JMS组件：activemq（慢） AMQP组件（advance message queue protocol

落日映苍穹つ/ 2022年03月15日 15:15/ 0 赞/ 329 阅读

相关【RabbitMQ】 Java简单的实现RabbitMQ

[https://www.cnblogs.com/h--d/p/10016741.html][https_www.cnblogs.com_h--d_p_10016741.

Dear 丶/ 2021年11月11日 14:20/ 0 赞/ 407 阅读

相关 RabbitMQ简单入门实例

1.Windows下安装RabbitMQ (1)：下载erlang，原因在于RabbitMQ服务端代码是使用并发式语言erlang编写的，下载地址：http://www

我会带着你远行/ 2021年09月26日 14:08/ 0 赞/ 414 阅读

相关 RabbitMQ（一）：Java简单操作RabbitMQ

Java简单操作RabbitMQ 前言一、添加pom依赖二、生产者三、消费者 ----

梦里梦外;/ 2021年09月24日 15:24/ 0 赞/ 496 阅读