SpringBoot gradle 中使用RabbitMQ（二）

发送端服务器

注册队列 -- 配置文件实现

@Configuration
public class RabbitConfig {
    //注册队列
    @Bean
    public Queue Queue(){
        return new Queue("hello");
    }
}

消息发送

@Component
public class MessageSender{

    @Autowired
    AmqpTemplate amqpTemplate;

    public void send() {
        String content = "hello " + new Date();
        System.out.println("Sender-message : " + content);
        this.amqpTemplate.convertAndSend("hello", content);
    }
}

接收端服务器

实现方式一

@Component
@RabbitListener(queues = "hello")
public class MessageReceiver {
    
    @RabbitHandler
    public void process(@Payload String foo) {
        System.out.println(foo);
    }
}

实现方式二：

@Component
public class MessageReceiver {

    @RabbitListener(queues = "hello")
    public void process(String content){
        System.out.println("Receiver Value : " + content);
    }

}

测试类

@RunWith(SpringJUnit4ClassRunner.class)
@SpringBootTest(classes = WebClientCoreApplication.class)
@WebAppConfiguration
public class RabbitTest {

    @Autowired
    MessageSender messageSender;

    @Test
    public void testRabbit(){
        messageSender.send();
    }
}
//WebClientCoreApplication 为当前服务的启动类

测试过程

• 启动接收服务器
• 执行测试类

期望值

• 发送服务器正常打印
• 接收服务器正常打印
• RabbitMQ 管理端可以正常查阅发送记录