spring cloud bus - JavaShuo

RabbitMQ

在docker中运行rabbitmqjava

docker run -d -p 5672:5672  -p 8080:15672 rabbitmq:3-management

浏览器打开：http://10.202.203.29:8080/spring

默认用户名/密码都是guestdocker

在Admin页面添加用户浏览器

新添加的用户是没有权限的app

点击用户名进去，按提示添加权限ide

这样就能够在程序中访问了。单元测试

建立spring boot 项目，添加pom依赖测试

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

View Code

添加发送类Sender编码

import org.springframework.amqp.core.AmqpTemplate; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Component; import java.util.Date; @Component public class Sender { @Autowired private AmqpTemplate amqpTemplate; public void send(){ String context="hello "+new Date(); System.out.println("Sender: "+context); amqpTemplate.convertAndSend("hello",context); } }

View Code

添加接收类Receiverspa

import org.springframework.amqp.rabbit.annotation.RabbitHandler; import org.springframework.amqp.rabbit.annotation.RabbitListener; import org.springframework.stereotype.Component; @Component public class Receiver { @RabbitListener(queues = "hello") @RabbitHandler public void process(String hello){ System.out.println("Receiver: "+hello); } }

View Code

注意这里的@RabbitListener(queues = "hello")不要加在类上，而是加在方法上，官方的教程这里是错误的

添加配置类RabbitConfig

import org.springframework.amqp.core.Queue; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; @Configuration public class RabbitConfig { @Bean public Queue helloQueue(){ return new Queue("hello"); } }

View Code

配置文件

spring.application.name=rabbitmq-hello spring.rabbitmq.host=10.202.203.29 spring.rabbitmq.port=5672 spring.rabbitmq.username=springcloud spring.rabbitmq.password=123456

View Code

单元测试

@RunWith(SpringRunner.class) @SpringBootTest public class RabbitmqHelloApplicationTests { @Autowired private Sender sender; @Test public void contextLoads() { sender.send(); } }

View Code

启动应用，在RabbitMQ管理界面中查看链接

运行单元测试，能够在控制台看到结果

再查看管理页面

开启应用的接受监控后，能够在rabbitmq管理界面直接发送消息，须要指定编码格式

在控制台能够看到接收到了消息