文章详情

短信预约-IT技能 免费直播动态提醒

请输入下面的图形验证码

提交验证

短信预约提醒成功

Java中SpringBoot如何整合RabbitMQ

2023-06-05 04:23

关注

这篇文章主要为大家展示了“Java中SpringBoot如何整合RabbitMQ”,内容简而易懂,条理清晰,希望能够帮助大家解决疑惑,下面让小编带领大家一起研究并学习一下“Java中SpringBoot如何整合RabbitMQ”这篇文章吧。

如果要进行 RabbitMQ 整合的时候一定要注意以下几个概念:交换空间、虚拟主机、队列信息。本次为了方便起见将项目分为 两个:RabbitMQ-Consumer、RabbitMQ-Producer。

【两个项目】将 rabbitmq 的依赖支持包拷贝到项目之中;

 <dependency>            <groupId>org.springframework.boot</groupId>            <artifactId>spring-boot-starter-amqp</artifactId>        </dependency>

【microboot-rabbitmq-producer、microboot-rabbitmq-consumer】修改 application.yml 配置文件,追加 rabbitmq 的相关配置项:

server:  port: 80spring:  messages:    basename: i18n/Messages,i18n/Pages  rabbitmq:    addresses: rabbitmq-server    username: studyjava    password: hello    virtual-host: /

 3、【microboot-rabbitmq-producer】建立一个消息的发送接口:

package cn.study.microboot.producer;public interface IMessageProducerService {    public void sendMessage(String msg) ;}

【microboot-rabbitmq-producer】为了可以正常使用 RabbitMQ 进行消息处理,你还需要做一个消息生产配置类;

package cn.study.microboot.config;import org.springframework.amqp.core.Binding;import org.springframework.amqp.core.BindingBuilder;import org.springframework.amqp.core.DirectExchange;import org.springframework.amqp.core.Queue;import org.springframework.context.annotation.Bean;import org.springframework.context.annotation.Configuration;@Configurationpublic class ProducerConfig {    public static final String EXCHANGE = "study.microboot.exchange"; // 交换空间名称    public static final String ROUTINGKEY = "study.microboot.routingkey"; // 设置路由key    public static final String QUEUE_NAME = "study.microboot.queue"; // 队列名称    @Bean    public Binding bindingExchangeQueue(DirectExchange exchange,Queue queue) {        return BindingBuilder.bind(queue).to(exchange).with(ROUTINGKEY) ;    }    @Bean    public DirectExchange getDirectExchange() { // 使用直连的模式        return new DirectExchange(EXCHANGE, true, true);    }    @Bean    public Queue queue() { // 要创建的队列信息        return new Queue(QUEUE_NAME);    }}

【microboot-rabbitmq-producer】创建消息服务的实现子类:

package cn.study.microboot.producer.impl;import javax.annotation.Resource;import org.springframework.amqp.rabbit.core.RabbitTemplate;import org.springframework.stereotype.Service;import cn.study.microboot.config.ProducerConfig;import cn.study.microboot.producer.IMessageProducerService;@Servicepublic class MessageProducerServiceImpl implements IMessageProducerService {    @Resource    private RabbitTemplate rabbitTemplate;    @Override    public void sendMessage(String msg) {        this.rabbitTemplate.convertAndSend(ProducerConfig.EXCHANGE,                ProducerConfig.ROUTINGKEY, msg);    }}

【microboot-rabbitmq-consumer】依然需要做一个消费者的配置程序类,而这个程序类里面主要的目的依然是设置交换空间、 路由 KEY 等信息。

package cn.study.microboot.config;import org.springframework.amqp.core.Binding;import org.springframework.amqp.core.BindingBuilder;import org.springframework.amqp.core.DirectExchange;import org.springframework.amqp.core.Queue;import org.springframework.context.annotation.Bean;import org.springframework.context.annotation.Configuration;@Configurationpublic class ConsumerConfig {    public static final String EXCHANGE = "study.microboot.exchange"; // 交换空间名称    public static final String ROUTINGKEY = "study.microboot.routingkey"; // 设置路由key    public static final String QUEUE_NAME = "study.microboot.queue"; // 队列名称    @Bean    public Queue queue() { // 要创建的队列信息        return new Queue(QUEUE_NAME);    }    @Bean    public DirectExchange getDirectExchange() { // 使用直连的模式        return new DirectExchange(EXCHANGE, true, true);    }    @Bean    public Binding bindingExchangeQueue(DirectExchange exchange,Queue queue) {        return BindingBuilder.bind(queue).to(exchange).with(ROUTINGKEY) ;    }}

【microboot-rabbitmq-consumer】实现监听处理类:

package cn.study.microboot.consumer;import org.springframework.amqp.rabbit.annotation.RabbitListener;import org.springframework.stereotype.Service;@Servicepublic class MessageConsumerService {    @RabbitListener(queues="study.microboot.queue")    public void receiveMessage(String text) {    // 进行消息接收处理        System.err.println("【*** 接收消息 ***】" + text);    }}

【microboot-rabbitmq-producer】创建一个测试类实现消息的发送处理。

package cn.study.microboot.test;import javax.annotation.Resource;import org.junit.Test;import org.junit.runner.RunWith;import org.springframework.boot.test.context.SpringBootTest;import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;import org.springframework.test.context.web.WebAppConfiguration;import cn.study.microboot.StartSpringBootMain;import cn.study.microboot.producer.IMessageProducerService;@SpringBootTest(classes = StartSpringBootMain.class)@RunWith(SpringJUnit4ClassRunner.class)@WebAppConfigurationpublic class TestActiveMQ {    @Resource    private IMessageProducerService messageProducer;    @Test    public void testSend() throws Exception {        for (int x = 0; x < 100; x++) {            this.messageProducer.sendMessage("study - " + x);        }    }}

【microboot-rabbitmq-consumer】编写消息接收测试类,这里面不需要编写代码,只需要做一个休眠即可:

package cn.study.microboot;import org.junit.Test;import org.junit.runner.RunWith;import org.springframework.boot.test.context.SpringBootTest;import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;import org.springframework.test.context.web.WebAppConfiguration;@SpringBootTest(classes = StartSpringBootMain.class)@RunWith(SpringJUnit4ClassRunner.class)@WebAppConfigurationpublic class AppTest {    @Test    public void testStart() throws Exception {        Thread.sleep(Long.MAX_VALUE);    }}

整体进行项目开发之中整合的处理步骤还是简单,但是千万要注意,由于是第一次整合处理,所以将生产者与消费者的配置 类分开了,实际上这两个类的作用是完全一样的。

以上是“Java中SpringBoot如何整合RabbitMQ”这篇文章的所有内容,感谢各位的阅读!相信大家都有了一定的了解,希望分享的内容对大家有所帮助,如果还想学习更多知识,欢迎关注编程网行业资讯频道!

阅读原文内容投诉

免责声明:

① 本站未注明“稿件来源”的信息均来自网络整理。其文字、图片和音视频稿件的所属权归原作者所有。本站收集整理出于非商业性的教育和科研之目的,并不意味着本站赞同其观点或证实其内容的真实性。仅作为临时的测试数据,供内部测试之用。本站并未授权任何人以任何方式主动获取本站任何信息。

② 本站未注明“稿件来源”的临时测试数据将在测试完成后最终做删除处理。有问题或投稿请发送至: 邮箱/279061341@qq.com QQ/279061341

软考中级精品资料免费领

  • 历年真题答案解析
  • 备考技巧名师总结
  • 高频考点精准押题
  • 2024年上半年信息系统项目管理师第二批次真题及答案解析(完整版)

    难度     813人已做
    查看
  • 【考后总结】2024年5月26日信息系统项目管理师第2批次考情分析

    难度     354人已做
    查看
  • 【考后总结】2024年5月25日信息系统项目管理师第1批次考情分析

    难度     318人已做
    查看
  • 2024年上半年软考高项第一、二批次真题考点汇总(完整版)

    难度     435人已做
    查看
  • 2024年上半年系统架构设计师考试综合知识真题

    难度     224人已做
    查看

相关文章

发现更多好内容

猜你喜欢

AI推送时光机
位置:首页-资讯-后端开发
咦!没有更多了?去看看其它编程学习网 内容吧
首页课程
资料下载
问答资讯