springboot使用消息中间件

springboot使用消息中间件

前言

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

内容

1.引入依赖

org.springframework.boot

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

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

@SpringBoodIzieUuktTest

public class ApplicationTests {

@Autowired

private TeacherRepository teacherRepository;

/*@Autowired

private javaMailSender javaMailSender;*/

@Autowired

private Sender sender;

@Test

public void contextLoads() {

//mq测试

sender.send();

}

}

版权声明：本文内容由网络用户投稿，版权归原作者所有，本站不拥有其著作权，亦不承担相应法律责任。如果您发现本站中有涉嫌抄袭或描述失实的内容，请联系我们jiasou666@gmail.com 处理，核实后本网站将在24小时内删除侵权内容。