新鲜出炉这是全网讲的最详细的springboot整合消息服务了吧建议收藏

springboot整合activeMq

ActiveMq是Apache提供的开源音讯零碎采纳java实现，

很好地反对JMS（Java Message Service,即Java音讯服务）标准

ActiveMq装置：http://activemq.apache.org/co… 在官网下载安装对应的版本

下载实现后解压就能够应用

ActiveMq默认的端口号是8161，用户名和明码都是admin 在本机能够应用http://localhost:8161 去拜访

springboot整合ActiveMq

1、导入依赖

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

2、在properties文件中配置activeMq

spring.activemq.broker-url=tcp://localhost:61616
#如果是点对点（queue），那么此处默认应该是false，如果公布订阅，那么肯定设置为true
spring.activemq.packages.trust-all=true
spring.activemq.user=admin
spring.activemq.password=admin

3、编写queue（队列）

@Component
public class QueueBean{
    //创立一个队列实例
    @Bean
    Queue queue(){
        //这里设置的音讯是队列的名称
        return new ActiveMQQueue("hello.javaboy");
    }
}

4、创立音讯的发送者以及消费者

@Component
public class JmsComponent{
    //springboot提供的音讯模板
    @Autowired
    JmsMessagingTemplate jmsMessagingTemplate;
    //本人创立的队列实例
    @Autowired
    Queue queue;
    /**
     * 发送音讯
     * @param message
     */
    public void send(Message message){
        jmsMessagingTemplate.convertAndSend(this.queue,message);
    }
    /**
     * 接管音讯
     * @param message
     */
    //示意监听该队列名称发来的音讯
    @JmsListener(destination = "hello.javaboy")
    public void readMessage(Message message){
        System.out.println(message);
    }

}

5、上述Message实体类

public class Message implements Serializable {
    private String content;//音讯主体
    private Date sendDate;//音讯发送的工夫
    //省略get、set、tostring办法
}

6、进行音讯的发送以及生产

在测试类中注入JmsComponent 调用send()办法进行音讯的转发

@SpringBootTest
class ActivemqApplicationTests {
    @Autowired
    JmsComponent jmsComponent;
    @Test
    void contextLoads() {
        Message message = new Message();
        message.setContent("hello activeMq");
        message.setSendDate(new Date());
        jmsComponent.send(message);
    }
}

首先启动我的项目，在运行测试类进行音讯发送：

控制台会打印消息内容：

springboot整合RabbitMQ

rabbitmq装置比拟繁琐，这里应用docker容器进行装置，docker装置十分不便，一条命令全副搞定

通过docker装置rabbitmq

-P(大p)示意主动映射到主机端口

docker run -d --hostname my-rabbitmq --name some-rabbitmq -P rabbitmq:3-management

首先导入依赖

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

编写配置文件：

#配置rabbitMQ
spring.rabbitmq.host=localhost
spring.rabbitmq.username=guest
spring.rabbitmq.password=guest
spring.rabbitmq.port=32771

RabbitMQ 四种替换模式：

直连交换机：Direct exchange

扇形交换机：Fanout exchange

主体交换机：Topic exchange

首部交换机：Headers exchange

上面别离介绍4中替换模式：

1、Direct exchange

//Direct策略（只转发给routingKey相匹配的用户）
@Configuration
public class RabbitDirectConfig {
    public final static String DIRECTNAME = "javaboy-direct";
    //音讯队列
    @Bean
    Queue queue(){
        //name值为队列名称，routingKey会与他进行匹配
        return new Queue("hello.RabbitMQ");
    }
    @Bean
    Queue queue1(){
        return new Queue("hello.RabbitMQ1");
    }
    @Bean
    DirectExchange directExchange(){
        //第一个参数为DIRECTNAME、第二个参数示意重启后是否无效，第三参数示意长时间未应用是否删除
        return new DirectExchange(DIRECTNAME,true,false);
    }
    @Bean
    Binding binding(){
        //将队列queue和DirectExchange绑定在一起
        return BindingBuilder.bind(queue()).to(directExchange()).with("direct");
    }
    @Bean
    Binding binding1(){
        //将队列queue和DirectExchange绑定在一起
        return BindingBuilder.bind(queue1()).to(directExchange()).with("direct");
    }

}

2、配置消费者DirectReceiver：

//配置消费者
@Component
public class DirectReceiver {
    //只监听queue()队列的音讯
    @RabbitListener(queues = "hello.RabbitMQ")
    public void hanlder(String msg){
        System.out.println("hanlder>>>"+msg);

    }
    //只监听queue1()队列的音讯
    @RabbitListener(queues = "hello.RabbitMQ1")
    public void hanlder1(String msg){
        System.out.println("hanlder1>>>"+msg);

    }
}

测试代码：

在springboot的测试类中注入RabbitTemplate(springboot提供的RabbitMQ模板)

 @Autowired
    RabbitTemplate rabbitTemplate;
    @Test
    void contextLoads() {
        //两个参数第一个是routingKey、第二个为音讯内容
        rabbitTemplate.convertAndSend("hello.RabbitMQ","hello RabbitMQ test");
        rabbitTemplate.convertAndSend("hello.RabbitMQ1","hello RabbitMQ test222");
    }

启动我的项目后，运行测试类能够看到只有与routingkey相匹配的消费者受到了对应的音讯：

2、Fanout exchange

Fanout策略（只有是与他绑定的队列，都会收到音讯与routingKey无关）

1、配置RabbitFanoutConfig：

//Fanout策略（只有是与他绑定的队列，都会收到音讯与routingKey无关）
@Configuration
public class RabbitFanoutConfig {
    public final static String FANOUTNAME = "javaboy-fanout";
    //配置了两个音讯队列queueOne和queueTwo
    @Bean
    Queue queueOne(){
        return new Queue("queue-one");
    }
    @Bean
    Queue queueTwo(){
        return new Queue("queue-two");
    }
    @Bean
    FanoutExchange fanoutExchange(){
        return new FanoutExchange(FANOUTNAME,true,false);
    }
    //将两个队列与FanoutExchange绑定
    @Bean
    Binding bindingOne(){
        return BindingBuilder.bind(queueOne()).to(fanoutExchange());
    }
    @Bean
    Binding bindingTwo(){
        return BindingBuilder.bind(queueTwo()).to(fanoutExchange());
    }
}

2、配置消费者FanoutReceiver：

//配置消费者
@Component
public class FanoutReceiver {
    //两个消费者别离监听两个不同的队列
    @RabbitListener(queues = "queue-one")
    public void hanlder1(String msg){
        System.out.println("FanoutReceiver:hanlder1>>>"+msg);

    }
    @RabbitListener(queues = "queue-two")
    public void hanlder2(String msg){
        System.out.println("FanoutReceiver:hanlder2>>>"+msg);

    }
}

3、测试类：

@Test
    void rabbitFanout(){
        //三个参数示意RabbitFanoutConfig的名称、routingkey、音讯内容
        rabbitTemplate.convertAndSend(RabbitFanoutConfig.FANOUTNAME,null,"hello fanout test");
    }

该形式与routingkey无关所有写null即可

查看输入：能够看到两个消费者都收到了音讯

3、Topic exchange

topic策略能够依据routingKey的规定（通配符形式）进行去匹配队列进行转发规定为.#. *为单词，#示意含糊匹配

例如routingkey为：xiaomi.# 那么带有xiaomi.结尾的队列都会收到该音讯

routingkey为：#.phone.# 示意音讯的routingKey中带有phone时就会去匹配带有phone的队列

1、配置RabbitTopicConfig：

/topic策略能够依据routingKey的规定（通配符形式）进行去匹配队列进行转发规定为*.#.*
    //*为单词，#示意含糊匹配
@Configuration
public class RabbitTopicConfig {
    public final static String TOPICNAME = "javaboy-topic";

    @Bean
    TopicExchange topicExchange(){
        return new TopicExchange(TOPICNAME,true,false);
    }
    @Bean
    Queue xiaomi(){
        return new Queue("xiaomi");
    }
    @Bean
    Queue huawei(){
        return new Queue("huawei");
    }
    @Bean
    Queue phone(){
        return new Queue("phone");
    }

    @Bean
    Binding xiaomiBinding(){
        //xiaomi.#：示意音讯的routingKey是以xiaomi结尾的就会路由到xiaomi的队列
        return BindingBuilder.bind(xiaomi()).to(topicExchange()).with("xiaomi.#");
    }
    @Bean
    Binding huaweiBinding(){
        return BindingBuilder.bind(huawei()).to(topicExchange()).with("huawei.#");
    }
    @Bean
    Binding phoneBinding(){
        //#.phone.#：示意音讯的routingKey中带phone的都会路由到phone的队列
        return BindingBuilder.bind(phone()).to(topicExchange()).with("#.phone.#");
    }
}

2、配置消费者TopicReceiver：

@Component
public class TopicReceiver {
    //别离监听名称为xiaomi、huawei、phone的队列
    @RabbitListener(queues = "xiaomi")
    public void handlerXM(String msg){
        System.out.println("TopicReceiver:handlerXM>>>"+msg);
    }
    @RabbitListener(queues = "huawei")
    public void handlerHW(String msg){
        System.out.println("TopicReceiver:handlerHW>>>"+msg);
    }
    @RabbitListener(queues = "phone")
    public void handlerPHONE(String msg){
        System.out.println("TopicReceiver:handlerPHONE>>>"+msg);
    }
}

3、测试类：

@Test
    void rabbitTopic(){
        //依据匹配规定该音讯只能被xiaomi的队列收到
        rabbitTemplate.convertAndSend(RabbitTopicConfig.TOPICNAME,"xiaomi.news","小米新闻");
        //依据匹配规定该音讯只能被phone的队列收到
        rabbitTemplate.convertAndSend(RabbitTopicConfig.TOPICNAME,"vivo.phone","vivo手机");
        //依据匹配规定该音讯能够别huawei和phone两个队列收到
        rabbitTemplate.convertAndSend(RabbitTopicConfig.TOPICNAME,"huawei.phone","华为手机");

    }

查看输入：

能够看到routingkey为huawei.phone的音讯匹配了两个队列，其余两个都只匹配了一个队列

4、Headers exchange

该模式是依据路由规定的header进行匹配的，在进行匹配的时候须要传入一个map汇合，routingkey去匹配map即可中的key value，匹配规定能够使any或者all，any示意只有蕴含任意信息就能够，all示意所有信息都必须匹配

1、配置RabbitHeaderConfig：

@Configuration
public class RabbitHeaderConfig {
    public final static String HEADERNAME = "javaboy-header";

    @Bean
    HeadersExchange headersExchange(){
        return new HeadersExchange(HEADERNAME,true,false);
    }
    //别离创立两个不同header的队列
    @Bean
    Queue queueName(){
        return new Queue("name-queue");
    }
    @Bean
    Queue queueAge(){
        return new Queue("age-queue");
    }
    @Bean
    Binding bindingName(){
        Map<String,Object> map = new HashMap<>();
        map.put("name","hello");
        //示意如果routingKey匹配的map汇合中的key value 就会将音讯转发到对应的路由上
        return BindingBuilder.bind(queueName()).to(headersExchange()).whereAny(map).match();
    }

    @Bean
    Binding bindingAge(){
        return BindingBuilder.bind(queueAge()).to(headersExchange()).where("age").exists();
    }
}

2、创立消费者HeaderReceiver:

@Component
public class HeaderReceiver {
    @RabbitListener(queues = "name-queue")
    public void handlerName(byte[] msg){
        System.out.println("HeaderReceiver:handlerName>>>>"+new String(msg,0,msg.length));
    }
    @RabbitListener(queues = "age-queue")
    public void handlerAge(byte[] msg){
        System.out.println("HeaderReceiver:handlerAge>>>>"+new String(msg,0,msg.length));
    }
}

3、测试代码：

@Test
    public void rabbitHeader(){
        //设置音讯，并且设置header，setHeader("name","hello")别离示意map汇合中的key、value
        Message nameMessage = 
            MessageBuilder.withBody("hello name".getBytes()).setHeader("name","hello").build();
        Message ageMessage =
            MessageBuilder.withBody("hello 99 age".getBytes()).setHeader("age","99").build();
        rabbitTemplate.send(RabbitHeaderConfig.HEADERNAME,null,nameMessage);
        rabbitTemplate.send(RabbitHeaderConfig.HEADERNAME,null,ageMessage);
    }

查看输入：

扭转setheader中的值查看后果：

 Message nameMessage = 
            MessageBuilder.withBody("hello name".getBytes()).setHeader("name","javaboy").build();

能够看到因为key、value匹配不上只打印了一条音讯。

最初

大家看完有什么不懂的能够在下方留言探讨，也能够关注我私信问我，我看到后都会答复的。也欢送大家关注我的公众号：前程有光，金三银四跳槽面试季，整顿了1000多道将近500多页pdf文档的Java面试题材料，文章都会在外面更新，整顿的材料也会放在外面。谢谢你的观看，感觉文章对你有帮忙的话记得关注我点个赞反对一下！

新鲜出炉这是全网讲的最详细的springboot整合消息服务了吧建议收藏

springboot整合activeMq

springboot整合ActiveMq

1、导入依赖

2、在properties文件中配置activeMq

3、编写queue（队列）

4、创立音讯的发送者以及消费者

5、上述Message实体类

6、进行音讯的发送以及生产

springboot整合RabbitMQ

RabbitMQ 四种替换模式：

1、Direct exchange

2、配置消费者DirectReceiver：

Fanout策略（只有是与他绑定的队列，都会收到音讯与routingKey无关）

1、配置RabbitFanoutConfig：

2、配置消费者FanoutReceiver：

3、测试类：

3、Topic exchange

1、配置RabbitTopicConfig：

2、配置消费者TopicReceiver：

3、测试类：

4、Headers exchange

1、配置RabbitHeaderConfig：

2、创立消费者HeaderReceiver:

3、测试代码：

最初

评论

发表回复取消回复

更多文章

DDN HPC 存储硬件架构设计深度分析

探秘IO500：从Lustre并行文件系统出发，开启HPC存储性能新征程

苹果iOS打包的ipa应用无法安装？一篇文章带你了解可能的原因及排查方法

图解Golang：从零开始实现简易版过期LRU缓存

新鲜出炉这是全网讲的最详细的springboot整合消息服务了吧建议收藏

springboot整合activeMq

springboot整合ActiveMq

1、导入依赖

2、在properties文件中配置activeMq

3、编写queue（队列）

4、创立音讯的发送者以及消费者

5、上述Message实体类

6、进行音讯的发送以及生产

springboot整合RabbitMQ

RabbitMQ 四种替换模式：

1、Direct exchange

2、配置消费者DirectReceiver：

Fanout策略（只有是与他绑定的队列，都会收到音讯与routingKey无关）

1、配置RabbitFanoutConfig：

2、配置消费者FanoutReceiver：

3、测试类：

3、Topic exchange

1、配置RabbitTopicConfig：

2、配置消费者TopicReceiver：

3、测试类：

4、Headers exchange

1、配置RabbitHeaderConfig：

2、创立消费者HeaderReceiver:

3、测试代码：

最初

评论

发表回复 取消回复

更多文章

DDN HPC 存储硬件架构设计深度分析

探秘IO500：从Lustre并行文件系统出发，开启HPC存储性能新征程

苹果iOS打包的ipa应用无法安装？一篇文章带你了解可能的原因及排查方法

图解Golang：从零开始实现简易版过期LRU缓存

发表回复取消回复