修改rabbitmq，增加对AI，骨龄评价消息队列的支持

侯瑞军

2020-05-06 528fa00bade64ddc7aa2c9978d37e2ab5168afd1

修改rabbitmq，增加对AI，骨龄评价消息队列的支持

 kidgrow-business/kidgrow-mqcenter/kidgrow-mqcenter-rabbit/src/main/java/com/kidgrow/rabbitmq/recieve/TopicReceive.java

@@ -15,7 +15,7 @@
 * @Author: <a href="4345453@kidgrow.com">liuke</a>
 */
@Component
@RabbitListener(queues = "test_queue")
@RabbitListener(queues = "AdvancedEvaluation")
public class TopicReceive {
    @RabbitHandler
    public void process(String messages, Message message, Channel channel) {

 kidgrow-business/kidgrow-mqcenter/kidgrow-mqcenter-rabbit/src/main/java/com/kidgrow/rabbitmq/send/TopicSender.java

@@ -1,6 +1,6 @@
package com.kidgrow.rabbitmq.send;

import org.springframework.amqp.core.AmqpTemplate;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

@@ -14,12 +14,17 @@
 */
@Component
public class TopicSender {
//    @Autowired
//    private AmqpTemplate rabbitTemplate;

    @Autowired
    private AmqpTemplate rabbitTemplate;
    private RabbitTemplate rabbitTemplate;


    public void send() {
        for(int i=1;i<10000;i++) {
            String context = "hi, i am message:"+i;
            this.rabbitTemplate.setQueue("AIEvaluation");
            this.rabbitTemplate.convertAndSend("test_exchange", "test_routingKey", context);
        }
    }

 kidgrow-commons/kidgrow-rabbitmq-spring-boot-starter/src/main/java/com/kidgrow/rabbitmq/config/RabbitConfig.java

@@ -127,7 +127,27 @@
    }

    @Bean
    Binding bindingExchangeMessage(Queue kidgrowQueue, TopicExchange exchange) {
        return BindingBuilder.bind(kidgrowQueue).to(exchange).with(routingKeyName);
    Binding bindingExchangeMessage(TopicExchange exchange) {
        return BindingBuilder.bind(KidgrowQueue()).to(exchange).with(routingKeyName);
    }

    @Bean
    public Queue AIEvaluation() {
        return new Queue("AIEvaluation");
    }

    @Bean
    Binding bindingExchangeAIEvaluation(TopicExchange exchange) {
        return BindingBuilder.bind(AIEvaluation()).to(exchange).with(routingKeyName);
    }

    @Bean
    public Queue AdvancedEvaluation() {
        return new Queue("AdvancedEvaluation");
    }

    @Bean
    Binding bindingExchangeAdvancedEvaluation(TopicExchange exchange) {
        return BindingBuilder.bind(AdvancedEvaluation()).to(exchange).with(routingKeyName);
    }
}