ICode9
精准搜索请尝试： 精确搜索
首页
编程语言>
数据库
系统相关
互联网
其他分享
Python
Java
JavaScript
android
PHP
首页 > 其他分享> 文章详细

SpringBoot集成RabbitMQ

2021-10-06 21:59:36  阅读：126  来源： 互联网

标签：集成 SpringBoot springframework RabbitMQ import msg org public amqp


如今较为流行的消息中间件，例如RabbitMQ和Kafka，在此介绍使用SpringBoot集成RabbitMQ。

1.引入SpringBoot集成的RabbitMQ的启动包依赖，因为SpringBoot对RabbitMQ有着很好的集成，所以在导入依赖时，这里我的SpringBoot使用的是最新版的：

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

2.配置配置文件application.yml，在此注意我们的ip地址和端口号就行：

server:
  port: 8021
spring:
  application:
    name: rabbitmq-provider

  //配置我们的rabbitmq的主机地址，本机Windows的话就用127.0.0.1，其他主机的话就用ip地址，这里我使用的是我的服务器ip地址
  rabbitmq:
    host: 101.35.105.175
    //配置我们的rabbitmq的端口号，开放的一般是5672
    port: 5672
    username: admin
    password: 123
    #虚拟host 可以不设置,使用server默认host
    virtual-host: JCcccHost

3.创建好我们的工程之后，创建生产者：这里我们对各个不同的rabbitmq的工作模式分别创建不同：

3.1、HelloWorld模式：
生产者：这里我们使用RabbitTemplate 的模板对象，我们只需对其进行注入就能使用RabbitTemplate 对象对消息进行操作。

@SpringBootTest(classes = SpringbootRabbitmqApplication.class)
@RunWith(SpringRunner.class)
public class HelloWorldDemo {
    @Autowired
    RabbitTemplate rt;

    @Test
    public void send() {
        rt.convertAndSend("hello-world","hello world!!!");
    }
}

消费者：
使用@RabbitListener(queuesToDeclare = @Queue(“hello-world”))去对我们的队列进行绑定。
这里的msg参数，是接收生产者产生的消息。

@Component
@RabbitListener(queuesToDeclare = @Queue("hello-world"))
public class HelloWorld {

    @RabbitHandler
    public void receive(String msg){
        System.out.println("msg:"+msg);
    }
}

执行后：
执行结果
执行后自动生成的队列
3.2、work模式：
生产者：

package com.example.springbootrabbitmq.helloworld;
/*
    PACKAGE_NAME:com.example.springbootrabbitmq.helloworld
    USER:18413
    DATE:2021/10/6 18:29
    PROJECT_NAME:RabbitMq
    面向代码面向君，不负代码不负卿————蒋明辉 */


import com.example.springbootrabbitmq.SpringbootRabbitmqApplication;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.amqp.rabbit.annotation.RabbitHandler;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.test.context.junit4.SpringRunner;

@SpringBootTest(classes = SpringbootRabbitmqApplication.class)
@RunWith(SpringRunner.class)
public class HelloWorldDemo {
    @Autowired
    RabbitTemplate rt;

    @Test
    public void send() {
        for (int i = 0; i < 100; i++) {
            rt.convertAndSend("hello-world","hello world!!!"+i);
        }
    }
}

消费者：多个消费者，绑定一个消息队列，轮询方式消费信息

package com.example.springbootrabbitmq.helloworld;
/*
    PACKAGE_NAME:com.example.springbootrabbitmq.helloworld
    USER:18413
    DATE:2021/10/6 17:05
    PROJECT_NAME:RabbitMq
    面向代码面向君，不负代码不负卿————蒋明辉 */

import org.springframework.amqp.rabbit.annotation.Queue;
import org.springframework.amqp.rabbit.annotation.RabbitHandler;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

@Component
public class HelloWorld {

    @RabbitHandler
    @RabbitListener(queuesToDeclare = @Queue("hello-world"))
    public void receive01(String msg){
        System.out.println("receive01:"+msg);
    }
    @RabbitHandler
    @RabbitListener(queuesToDeclare = @Queue("hello-world"))
    public void receive02(String msg){
        System.out.println("receive02:"+msg);
    }
    @RabbitHandler
    @RabbitListener(queuesToDeclare = @Queue("hello-world"))
    public void receive03(String msg){
        System.out.println("receive03:"+msg);
    }
}

3.3、fanout模式——广播模式
生产者：
第一个参数：设置我们的交换机
第二个参数：设置routekey
第三个参数：消息体

@Test
    public void fanOutSend() {
        rt.convertAndSend("logs","","i am fanout");
    }

消费者：注解去绑定临时队列，绑定交换机，绑定消息类型

 @RabbitListener(bindings = {
            @QueueBinding(value = @Queue,
                    exchange = @Exchange(value = "logs",type = "fanout"))
    })
    public void receive02(String msg){
        System.out.println("receive02:"+msg);
    }
    @RabbitListener(bindings = {
            @QueueBinding(value = @Queue,
                    exchange = @Exchange(value = "logs",type = "fanout"))
    })
    public void receive03(String msg){
        System.out.println("receive03:"+msg);
    }

3.4、direct路由模式：绑定我们的路由key
生产者：

 @Test
    public void DirectSend() {
        rt.convertAndSend("route-directs","info","i am info");
        rt.convertAndSend("route-directs","error","i am error");
    }

消费者：

package com.example.springbootrabbitmq.direct;
/*
    PACKAGE_NAME:com.example.springbootrabbitmq.direct
    USER:18413
    DATE:2021/10/6 20:21
    PROJECT_NAME:RabbitMq
    面向代码面向君，不负代码不负卿————蒋明辉 */

import org.springframework.amqp.rabbit.annotation.Exchange;
import org.springframework.amqp.rabbit.annotation.Queue;
import org.springframework.amqp.rabbit.annotation.QueueBinding;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;

@Component
public class Direct {
    @RabbitListener(bindings = {
            @QueueBinding(value = @Queue,
                    key = {"info"},
                    exchange = @Exchange(value = "route-directs",type = "direct"))
    })
    public void receive01(String msg){
        System.out.println("receive01:"+msg);
    }
    @RabbitListener(bindings = {
            @QueueBinding(value = @Queue,
                    key = {"info","error"},
                    exchange = @Exchange(value = "route-directs",type = "direct"))
    })
    public void receive02(String msg){
        System.out.println("receive02:"+msg);
    }

}

3.5、Topic（动态路由）：
生产者：

@Test
    public void TopicSend() {
        rt.convertAndSend("route-Topic","info","i am info");
        rt.convertAndSend("route-Topic","info.save","i am info");
        rt.convertAndSend("route-Topic","info.save.send","i am info");
        rt.convertAndSend("route-Topic","error.save","i am error");
        rt.convertAndSend("route-Topic","error.save.send","i am error");
    }

消费者：

package com.example.springbootrabbitmq.topic;
/*
    PACKAGE_NAME:com.example.springbootrabbitmq.topic
    USER:18413
    DATE:2021/10/6 21:48
    PROJECT_NAME:RabbitMq
    面向代码面向君，不负代码不负卿————蒋明辉 */

import org.springframework.amqp.rabbit.annotation.Exchange;
import org.springframework.amqp.rabbit.annotation.Queue;
import org.springframework.amqp.rabbit.annotation.QueueBinding;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;

@Component
public class Topic {
    @RabbitListener(bindings = {
            @QueueBinding(value = @Queue,
                    key = {"info.*","error.*"},
                    exchange = @Exchange(value = "route-topic",type = "topic"))
    })
    public void receive01(String msg){
        System.out.println("receive01:"+msg);
    }
}

4、各位老板可以点个免费的关注吗 谢谢啦！！！

标签：集成,SpringBoot,springframework,RabbitMQ,import,msg,org,public,amqp
来源： https://blog.csdn.net/weixin_45969711/article/details/120626620

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。

关于我们 | 联系我们 | 留言反馈

专注分享技术，共同学习，共同进步。侵权联系[81616952@qq.com]

Copyright (C)ICode9.com, All Rights Reserved.

ICode9版权所有