RabbitMQ主要实现消息推送和消费

• 用springboot实现消息推送

  1. 新建springboot项目

通过idea，创建一个springboot默认项目，在pom.xml中添加如下依赖。

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

　　2.编写RabbitMQConfig类

/** * RabbitMQ配置类 */ @Configuration public class RabbitMQConfig { //交换机名称
public static final String ITEM_TOPIC_EXCHANGE = "item_topic_exchange"; //队列名称
public static final String ITEM_QUEUE = "item_queue"; //声明交换机
@Bean("itemTopicExchange") public Exchange topicExchange(){ return ExchangeBuilder.topicExchange(ITEM_TOPIC_EXCHANGE).durable(true).build();
} //声明队列
@Bean("itemQueue") public Queue itemQueue(){ return QueueBuilder.durable(ITEM_QUEUE).build();
} //绑定队列和交换机
@Bean public Binding itemQueueExchange(@Qualifier("itemQueue") Queue queue,
@Qualifier("itemTopicExchange") Exchange exchange){ return BindingBuilder.bind(queue).to(exchange).with("test.#").noargs();
}

}

3.编写SendMessageController

@RestController public class SendMessageController { //注入RabbitMQ的模板
@Autowired private RabbitTemplate rabbitTemplate; /** * 测试 */ @GetMapping("/sendmsg") public String sendMsg(@RequestParam String msg, @RequestParam String key){ /** * 发送消息
* 参数一：交换机名称
* 参数二：路由key: item.springboot-rabbitmq,符合路由item.#规则即可
* 参数三：发送的消息 */ rabbitTemplate.convertAndSend(RabbitMQConfig.ITEM_TOPIC_EXCHANGE ,key ,msg); //返回消息
return "发送消息成功！";
}
}

验证结果

启动程序，访问http://localhost:8080/sendmsg?msg=%E5%BC%A0%E4%B8%89%E8%AF%B4%E4%B9%A6&key=item.test

 然后去界面客户端看下对应的queue模块下可以看到增加了一个消息，如下图：

 说明消息成功发送到RabbitMQ的队列中了。接下来实现消费就可读取队列中的消息了。

• 用springboot实现消息消费

  1. 新建springboot项目

通过idea，创建一个springboot默认项目，在pom.xml中添加如下依赖。

<dependency>
<groupId>com.rabbitmq</groupId>
<artifactId>rabbitmq-client</artifactId>
<version>1.3.0</version>
</dependency>

　 2.创建监听类MyListener

@Component
@EnableRabbit public class MyListener {

@RabbitListener(queues \= "item\_queue") public void msg(String msg) {
    System.out.println("消费者消费了：" + msg);
}

}

3.启动服务

程序监听item_queue队列消息，并进行了消费。

　　注意问题：

　　rabbitmq在properties或者在yml中配置用户名密码等参数，如在application.yml中：

spring:
rabbitmq:
host: localhost
username: guest
password: guest
virtual-host: /

这些配置是默认的，不需要配置，除非你新建了自己的用户。通过从查看源码的角度我们就可以找到答案。一般来说在applicationd的配置文件中的参数，可以找到对应的XXProperties.class文件,如rabbitmq对应的就是RabbitProperties.class文件，打开如下图所示：

 默认host和用户名密码都是已经设定了的，如果是其他的用户那么就可以通过yml或者properties等配置文件进行自定义配置。

。