[大数据]RabbitMQ的使用

需要的依赖

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

配置文件
application.yml

#配置mq
spring:
  rabbitmq:
    host: 公网ip
    username: 用户名
    password: 密码

发送端

@Component
public class Sender {
//    自动注入RabbitMQ的模板类
    @Resource
    AmqpTemplate amqpTemplate;//RabbitMQ的模板类

    /*
    * 发送消息的方法
    */
    public void sent(String msg){
        //参数一：交换机秘钥
        //参数二：路由键
        //参数三：消息内容
        amqpTemplate.convertAndSend("directExchange","com.product.sms",msg);
    }
}

接收端

@Component
public class Receiver {
    /* @RabbitListener:
    *    bindings:绑定队列
    *    @QueueBinding:绑定队列的详细属性
    *    Queue:value 配置队列名称
    *    autoDelete:是否是可删除的临时队列
*/
    @RabbitListener(
            bindings=@QueueBinding(
                    //设置队列名称这个随便写 设置是否用完后自动销毁
                    value=@Queue(value="myDirect",autoDelete = "false"),
                    //设置交换机秘钥（在发送方设置了的） 设置交换机类型
                    exchange=@Exchange(value="directExchange",type= ExchangeTypes.DIRECT),
                    key="com.product.sms"
            )
    )
    public void onSms(String msg){
        System.out.println("收到信息了:"+msg);
    }

}

接收端注解如下

    /* @RabbitListener:
    *    bindings:绑定队列
    *    @QueueBinding:绑定队列的详细属性
    *    Queue:value 配置队列名称
    *    autoDelete:是否是可删除的临时队列
	*/
    @RabbitListener(
            bindings=@QueueBinding(
                    //设置队列名称这个随便写 设置是否用完后自动销毁
                    value=@Queue(value="myDirect",autoDelete = "false"),
                    //设置交换机秘钥（在发送方设置了的） 设置交换机类型
                    exchange=@Exchange(value="directExchange",type= ExchangeTypes.DIRECT),
                    key="com.product.sms"
            )
    )

测试

    public void test01(){
        while (true){
            sender.sent("这是sender送出的第"+i+++"条消息");
            try {
                Thread.sleep(1000);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }