Loading [MathJax]/jax/output/CommonHTML/config.js
首页
学习
活动
专区
圈层
工具
发布
首页
学习
活动
专区
圈层
工具
MCP广场
社区首页 >专栏 >RabbitMQ消息队列

RabbitMQ消息队列

作者头像
用户10521079
发布于 2023-05-04 11:02:26
发布于 2023-05-04 11:02:26
43100
代码可运行
举报
文章被收录于专栏:Smile博客Smile博客
运行总次数:0
代码可运行

1.安装

代码语言:javascript
代码运行次数:0
运行
AI代码解释
复制
RabbitMQ部署指南
1.单机部署
我们在Centos7虚拟机中使用Docker来安装。

1.1.下载镜像
方式一:在线拉取

docker pull rabbitmq:3-management
方式二:从本地加载

在课前资料已经提供了镜像包:

image-20210423191210349

上传到虚拟机中后,使用命令加载镜像即可:

docker load -i mq.tar
1.2.安装MQ
执行下面的命令来运行MQ容器:

docker run \
 -e RABBITMQ_DEFAULT_USER=itcast \
 -e RABBITMQ_DEFAULT_PASS=123321 \
 --name mq \
 --hostname mq1 \
 -p 15672:15672 \
 -p 5672:5672 \
 -d \
 rabbitmq:3-management
2.集群部署
接下来,我们看看如何安装RabbitMQ的集群。

2.1.集群分类
在RabbitMQ的官方文档中,讲述了两种集群的配置方式:

普通模式:普通模式集群不进行数据同步,每个MQ都有自己的队列、数据信息(其它元数据信息如交换机等会同步)。例如我们有2MQ:mq1,和mq2,如果你的消息在mq1,而你连接到了mq2,那么mq2会去mq1拉取消息,然后返回给你。如果mq1宕机,消息就会丢失。
镜像模式:与普通模式不同,队列会在各个mq的镜像节点之间同步,因此你连接到任何一个镜像节点,均可获取到消息。而且如果一个节点宕机,并不会导致数据丢失。不过,这种方式增加了数据同步的带宽消耗。
我们先来看普通模式集群。

2.2.设置网络
首先,我们需要让3MQ互相知道对方的存在。

分别在3台机器中,设置 /etc/hosts文件,添加如下内容:

192.168.150.101 mq1
192.168.150.102 mq2
192.168.150.103 mq3
并在每台机器上测试,是否可以ping通对方:

模型

2.spring集成消息队列

发布消息者代码编写

代码语言:javascript
代码运行次数:0
运行
AI代码解释
复制
@RunWith(SpringRunner.class)
@SpringBootTest
public class SpringAmqpTest {

    @Autowired
    private RabbitTemplate rabbitTemplate;

     @Test
    public  void  testSendMessage2SimpleQueue(){
          String queueName = "simple.queue";
          String message = "hellow ,spring amqp";

         rabbitTemplate.convertAndSend(queueName,message);

     }

}

接收消息者代码编写

代码语言:javascript
代码运行次数:0
运行
AI代码解释
复制
@Component
public class SpringRabbitListener {

    @RabbitListener(queues = "simple.queue")
    public void listenerSimpleQueue(String message){
        System.out.print("消费者接受带消费者的消息:"+ message);
    }

}

3. work queue 工作队列

提高消息处理速度,避免队列消息堆积
实现
配置消息预取

4.发布订阅

实现关系
创建队列交换机
代码语言:javascript
代码运行次数:0
运行
AI代码解释
复制
package cn.itcast.mq.config;

import org.assertj.core.annotations.Beta;
import org.springframework.amqp.core.Binding;
import org.springframework.amqp.core.BindingBuilder;
import org.springframework.amqp.core.FanoutExchange;
import org.springframework.amqp.core.Queue;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

@Configuration
public class FanoutConfig {
    //itcast.fanout  创建交换机
    @Bean
    public FanoutExchange FanoutExchange(){
        return new  FanoutExchange("itcast.fanout");
    }

    //fanout queue    创建队列
    @Bean
    public Queue fanoutQueue1(){
        return  new Queue("fanout queue1");
    }

    //绑定队列1到交换机
    public Binding  fanoutBingding(Queue fanoutQueue1,FanoutExchange FanoutExchange){
        return BindingBuilder
                .bind(fanoutQueue1)
                .to(FanoutExchange);
    }

    //fanout queue    创建队列
    @Bean
    public Queue fanoutQueue2(){
        return  new Queue("fanout queue2");
    }

    //绑定队列2到交换机
    public Binding  fanoutBingding2(Queue fanoutQueue2,FanoutExchange FanoutExchange){
        return BindingBuilder
                .bind(fanoutQueue2)
                .to(FanoutExchange);
    }


}
direct路由
消息转换器发送者

####消息转换器接收者

本文参与 腾讯云自媒体同步曝光计划,分享自作者个人站点/博客。
原始发表:2022-03-29,如有侵权请联系 cloudcommunity@tencent.com 删除

本文分享自 作者个人站点/博客 前往查看

如有侵权,请联系 cloudcommunity@tencent.com 删除。

本文参与 腾讯云自媒体同步曝光计划  ,欢迎热爱写作的你一起参与!

评论
登录后参与评论
暂无评论
推荐阅读
编辑精选文章
换一批
(二)什么是SpringAMQP
SpringAMQP是基于RabbitMQ封装的一套模板,并且还利用SpringBoot对其实现了自动装配,使用起来非常方便。
用户7630333
2023/12/07
2710
(二)什么是SpringAMQP
【RabbitMQ】整合 SpringBoot,实现工作队列、发布/订阅、路由和通配符模式
在发布/订阅模式中,多了一个 Exchange 角色。Exchange 常见有三种类型,分别代表不同的路由规则
椰椰椰耶
2025/05/18
2580
【RabbitMQ】整合 SpringBoot,实现工作队列、发布/订阅、路由和通配符模式
花了3天总结的RabbitMQ实用技巧,有点东西!
RabbitMQ是最受欢迎的开源消息中间件之一,在全球范围内被广泛应用。RabbitMQ是轻量级且易于部署的,能支持多种消息协议。RabbitMQ可以部署在分布式系统中,以满足大规模、高可用的要求。
macrozheng
2020/06/15
5530
RabbitMQ
两种方式各有优劣,打电话可以立即得到响应,但是你却不能跟多个人同时通话。发送邮件可以同时与多个人收发邮件,但是往往响应会有延迟。
roydonGuo
2023/02/27
1.4K0
RabbitMQ
RabbitMQ消息队列入门及解决常见问题
两种方式各有优劣,打电话可以立即得到响应,但是你却不能跟多个人同时通话。发送邮件可以同时与多个人收发邮件,但是往往响应会有延迟。
不吃紫菜
2023/02/13
2.3K0
RabbitMQ消息队列入门及解决常见问题
RabbitMQ之SpringAMQP
2、在生产者端编写测试类SpringAmqpTest,并利用RabbitTemplate实现消息发送:
叫我阿杰好了
2022/11/07
4100
RabbitMQ之SpringAMQP
RabbitMQ:第三章:Springboot集成RabbitMQ(直连模式,工作队列模式,发布订阅模式,路由模式,通配符模式)
RabbitMQ:第二章:Spring整合RabbitMQ(简单模式,广播模式,路由模式,通配符模式,消息可靠性投递,防止消息丢失,TTL,死信队列,延迟队列,消息积压,消息幂等性)
Java廖志伟
2022/03/07
5050
RabbitMQ:第三章:Springboot集成RabbitMQ(直连模式,工作队列模式,发布订阅模式,路由模式,通配符模式)
SpringBoot-RabbitMQ广播模式
程序员NEO
2023/09/27
4080
微服务学习计划——消息队列
我们在微服务中一个命令会逐渐调用各个微服务,但如果一一调用不仅需要微服务实时同步交互还会浪费效率
秋落雨微凉
2023/03/11
8280
微服务学习计划——消息队列
【RabbitMQ】Fanout、Direct、Topic、消息转换器
Exchange(交换机)只负责转发消息,不具备存储消息的能力,因此如果没有任何队列与Exchange绑定,或者没有符合路由规则的队列,那么消息会丢失!
陶然同学
2023/02/24
7520
【RabbitMQ】Fanout、Direct、Topic、消息转换器
SpringBoot教程(十五) | SpringBoot集成RabbitMq
RabbitMq是我们在开发过程中经常会使用的一种消息队列。今天我们来研究研究rabbitMq的使用。
一缕82年的清风
2022/04/08
9730
SpringBoot教程(十五) | SpringBoot集成RabbitMq
SpringBoot RabbitMQ 整合进阶版
RabbitMQ 是消息中间件的一种, 消息中间件即分布式系统中完成消息的发送和接收的基础软件. 这些软件有很多, 包括 ActiveMQ ( apache 公司的), RocketMQ (阿里巴巴公司的, 现已经转让给 apache), 还有性能极高的 Kafka。
botkenni
2022/05/06
3650
SpringBoot RabbitMQ 整合进阶版
【愚公系列】2023年11月 Java教学课程 203-RabbitMQ(SpringAMQP)
消息队列(Message Queue)是一种在软件系统中应用广泛的通信机制,用于在不同的模块或系统之间传递消息。消息队列的基本思想是将消息按照一定的规则存放在一个队列中,然后由接收方从队列中取走消息进行处理。
愚公搬代码
2025/06/02
900
【愚公系列】2023年11月 Java教学课程 203-RabbitMQ(SpringAMQP)
RabbitMQ的工作队列在Spring Boot中实现(详解常⽤的⼯作模式)
上文着重介绍RabbitMQ 七种工作模式介绍RabbitMQ 七种工作模式介绍_rabbitmq 工作模式-CSDN博客
用户11369558
2024/11/20
5050
RabbitMQ的工作队列在Spring Boot中实现(详解常⽤的⼯作模式)
快速入门RabbitMQ
两种方式各有优劣,打电话可以立即得到响应,但是你却不能跟多个人同时通话。发送邮件可以同时与多个人收发邮件,但是往往响应会有延迟。
Maynor
2022/03/30
4260
快速入门RabbitMQ
RabbitMQ与Spring的框架整合之Spring AMQP实战
  RabbitAdmin类可以很好的操作RabbitMQ,在Spring中直接进行注入即可。注意,autoStartup必须设置为true,否则Spring容器不会加载RabbitAdmin类。RabbitAdmin底层实现就是从Spring容器中获取Exchange交换机、Binding绑定、RoutingKey路由键以及Queue队列的@Bean声明。
别先生
2019/12/02
1.8K0
手把手带你Springboot整合RabbitMq ,一篇讲完
该篇文章内容较多,包括有rabbitMq相关的一些简单理论介绍,provider消息推送实例,consumer消息消费实例,Direct、Topic、Fanout的使用,消息回调、手动确认等。(但是关于rabbitMq的安装,就不介绍了)
java进阶架构师
2020/06/16
3.2K0
手把手带你Springboot整合RabbitMq ,一篇讲完
SpringBoot整合RabbitMQ 实现五种消息模型 详细教程
今天说下了消息队列中间件,各种队列性能对比,RabbitMQ队列,交换机(Exchange)以及消息 中间件的应用场景,然后带着大家一起实现RabbitMQ的五种消息模型。
全栈程序员站长
2022/08/28
1.4K0
SpringBoot整合RabbitMQ 实现五种消息模型 详细教程
RabbitMQ
消息(Message)是指在应用间传送的数据。消息可以非常简单,比如只包含文本字符串,也可以更复杂,可能包含嵌入对象。
许喜朝
2022/05/05
6950
RabbitMQ使用教程(超详细)
下载地址:http://www.rabbitmq.com/download.html
全栈程序员站长
2022/07/21
3.2K1
RabbitMQ使用教程(超详细)
推荐阅读
相关推荐
(二)什么是SpringAMQP
更多 >
领券
一站式MCP教程库,解锁AI应用新玩法
涵盖代码开发、场景应用、自动测试全流程,助你从零构建专属AI助手
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档