您的位置：首页 > 编程语言 > Java开发

springboot使用消息中间件

2019-10-21 18:05 1816 查看

前言

使用SpringBoot集成rabbitmq实现一个发送和接收

内容

1.引入依赖

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

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.发送类< 大专栏 zyzx(53)-springboot使用消息中间件/h5>

@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);
}
}

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();
}
}

以上就是本文的全部内容，希望对大家的学习有所帮助

您可能感兴趣的文章:

内容来自用户分享和网络整理，不保证内容的准确性，如有侵权内容，可联系管理员处理

标签： spring boot 消息中间件

相关文章推荐

新的分享

章节导航