RabbitMQ

轻松搞定rabbitMQ
到底什么时候使用MQ
消息队列之 RabbitMQ

MQ一共有三种路由器：广播，直接，主题。
其中广播模式下不需要routingKey，即绑定键。为了方便理解，主要记录一下最常用的直接模式路由器。

Paste_Image.png

在服务端：

//创建连接连接到RabbitMQ    
ConnectionFactory factory = new ConnectionFactory();
// 设置MabbitMQ所在主机ip或者主机名
factory.setHost("127.0.0.1");
// 创建一个连接
Connection connection = factory.newConnection();
// 创建一个频道
Channel channel = connection.createChannel();
//往路由器中发消息，指定绑定键routingKey为“black”
channel.basicPublish(EXCHANGE_NAME, "black", null, message.getBytes());

在接收端

        
        ConnectionFactory factory = new ConnectionFactory();
        // 设置MabbitMQ所在主机ip或者主机名
        factory.setHost("127.0.0.1");
        // 创建一个连接
        Connection connection = factory.newConnection();
        // 创建一个频道
        Channel channel = connection.createChannel();
        // 指定转发——广播
        channel.exchangeDeclare(EXCHANGE_NAME, "direct");
        // 声明一个随机队列，或者自定义一个队列
        String queueName = channel.queueDeclare().getQueue();
        //队列通过绑定键routingKey绑定到路由器上
        channel.queueBind(queueName, EXCHANGE_NAME,"black");

        // 创建队列消费者
        final Consumer consumer = new DefaultConsumer(channel) {
              @Override
              public void handleDelivery(String consumerTag, Envelope envelope, AMQP.BasicProperties properties, byte[] body) throws IOException {
                String message = new String(body, "UTF-8");
                System.out.println(" [x] Received '"  + envelope.getRoutingKey() + "':'" + message + "'");
              }
            };
          //获取服务端消息信息  
         channel.basicConsume(queueName, true, consumer);
    }