前往小程序,Get更优阅读体验!
立即前往
首页
学习
活动
专区
工具
TVP
发布
社区首页 >专栏 >RabbitMQ消息队列

RabbitMQ消息队列

作者头像
用户10521079
发布2023-05-04 19:02:26
3160
发布2023-05-04 19:02:26
举报
文章被收录于专栏:Smile博客Smile博客

1.安装

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

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

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

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

模型

2.spring集成消息队列

发布消息者代码编写

代码语言:javascript
复制
@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
复制
@Component
public class SpringRabbitListener {

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

}

3. work queue 工作队列

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

4.发布订阅

实现关系
创建队列交换机
代码语言:javascript
复制
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 删除。

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

评论
登录后参与评论
0 条评论
热度
最新
推荐阅读
目录
  • 1.安装
  • 模型
  • 2.spring集成消息队列
  • 3. work queue 工作队列
  • 4.发布订阅
    • direct路由
      • 消息转换器发送者
      相关产品与服务
      消息队列
      腾讯云消息队列 TDMQ 是分布式架构中的重要组件,提供异步通信的基础能力,通过应用解耦降低系统复杂度,提升系统可用性和可扩展性。TDMQ 产品系列提供丰富的产品形态,包含 CKafka、RocketMQ、RabbitMQ、Pulsar、CMQ 五大产品,覆盖在线和离线场景,满足金融、互联网、教育、物流、能源等不同行业和场景的需求。
      领券
      问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档