rabbitmq简单实例

落日映苍穹つ 2022-03-15 15:15 341阅读 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 条评论，341人围观）

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

相关阅读

相关 RabbitMQ 简单队列

一、简单队列官方内容参考：[http://www.rabbitmq.com/tutorials/tutorial-one-java.html][http_www.rab

超、凢脫俗/ 2024年03月25日 20:16/ 0 赞/ 84 阅读

相关 RabbitMQ简单使用

1.安装： [win10安装RabbitMQ][win10_RabbitMQ] 2.使用 2.0 pom <dependency>

分手后的思念是犯贱/ 2023年10月05日 10:43/ 0 赞/ 70 阅读

相关简单讲解RabbitMQ

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

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

相关 RabbitMQ —— 简单队列

前文 [消息中间件 —— 简介][Link 1] [RabbitMQ —— 介绍][RabbitMQ _] [RabbitMQ —— 下载、安装][RabbitMQ

逃离我推掉我的手/ 2023年02月15日 01:27/ 0 赞/ 27 阅读

相关 SpringBoot-RabbitMq 简单实例

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

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

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

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

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

相关 RabbitMQ入门实例

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

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

相关 rabbitmq简单实例

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

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

相关 RabbitMQ简单入门实例

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

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

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

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

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