这篇文章主要介绍了springboot使用消息中间件,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
前言
使用SpringBoot集成rabbitmq实现一个发送和接收
内容
1.引入依赖
org.springframework.bootspring-boot-starter-amqp
2.application.properties
#rabbitmq配置 spring.application.name=springboot-mq spring.rabbitmq.host=192.168.17.129 spring.rabbitmq.port=5672 spring.rabbitmq.username=mytest spring.rabbitmq.password=mytest
3.rabbitmap配置类
import org.springframework.amqp.core.Queue; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; @Configuration public class RabbitMQConfig { @Bean public Queue mqQueue(){ return new Queue("mqboot"); } }
4.发送类
@Component public class Sender { @Autowired private AmqpTemplate rabbitTemplate; public void send(){ String content = "send: hello"+new Date(); System.out.println("Sender:"+content) this.rabbitTemplate.convertAndSend("mqboot",content); } }
收类
@Component @RabbitListener(queues = "mqboot") public class Receiver { @RabbitHandler public void process(String data){ System.out.println("Receiver:"+data<span style="color:transparent">来源gaodai#ma#com搞*代#码网</span>); } }
6.测试
启动springBoot
如下显示表明:连接成功:
@RunWith(SpringRunner.class) @SpringBootTest public class ApplicationTests { @Autowired private TeacherRepository teacherRepository; /*@Autowired private JavaMailSender javaMailSender;*/ @Autowired private Sender sender; @Test public void contextLoads() { //mq测试 sender.send(); } }
以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持gaodaima搞代码网。
以上就是springboot使用消息中间件的详细内容，更多请关注gaodaima搞代码网其它相关文章！
搞代码网（gaodaima.com）提供的所有资源部分来自互联网，如果有侵犯您的版权或其他权益，请说明详细缘由并提供版权或权益证明然后发送到邮箱[email protected]，我们会在看到邮件的第一时间内为您处理，或直接联系QQ：872152909。本网站采用BY-NC-SA协议进行授权
转载请注明原文链接：springboot使用消息中间件
转载请注明原文链接：springboot使用消息中间件
