参考demo：G:\学习资料\java\java学习文档\java技术文档\消息队列文档\rabbimitmq\cd-xufei-rabbiitmq-parent\cd-xufei-rabbitmq-01 => routing

这种模式和路由的key相关 ，只有当队列的key和交换机的key相同的时候，队列才能接收到消息

生产者写法

查看示例

public class Producer {

    /**
     * 申明了一个交换机的名字
     */
    private static final String EXCHANGE_NAME = "exchange_routing";

    public static void main(String[] args) throws Exception {
        // 第一步获取连接
        Connection connection = ConnectionUtils.getConnection();
        // 建立通道
        Channel channel = connection.createChannel();
        // 申明一个交换机
        /**
         * 第一个参数：交换机的名字
         * 第二个参数：交换机的类型  这里要注意  路由模型的话 这里的类型是不能乱写的 只能是 direct
         */
        channel.exchangeDeclare(EXCHANGE_NAME, "direct");

        // 接下来发送数据到交换机
        /**
         * 第一个参数：交换机的名字
         * 第二个参数：路由的key  路由模型下只有这个key和交换机的路由相同才能接受到消息
         * 第三个参数：发送消息的时候  附带的一些属性信息
         * 第四个参数：发送的这个消息体的内容
         */
        for (int i = 0; i < 100; i++) {
            channel.basicPublish(EXCHANGE_NAME, "xiaofeifei", null, ("路由模型的参数" + i).getBytes());
        }

    }
}

消费者1写法

查看示例

public class Consumer1 {

    /**
     * 申明了一个交换机的名字
     */
    private static final String EXCHANGE_NAME = "exchange_routing";
    /**
     * 声明与交换机绑定的这个队列的名字
     */
    private static final String QUEUE_NAME = "exchange_routing_que_1";

    public static void main(String[] args) throws Exception {
        // 第一步获取连接
        Connection connection = ConnectionUtils.getConnection();
        // 建立通道
        Channel channel = connection.createChannel();
        // 申明一个队列
        /**
         *第一个参数：队列的名字
         *第二个参数：是否持久化  ：这个数据 发送到队列去的时候 这个数据 是否要持久化到数据库中去
         *第三个参数：是否排外
         *           第一个意思：是否允许这个通道以外的 其他消费者来消费这个数据
         *           第二个意思：连接关闭之后  这个队列是否自动删除
         *第四个参数：是否自动删除
         *           表示的是 当最后一个连接退出的时候是否要删除这个队列
         *第五个参数：创建队列 付带的头的信息(TTL   死信队列)
         *
         */
        channel.queueDeclare(QUEUE_NAME, false, false, false, null);
        // 声明交换机
        channel.exchangeDeclare(EXCHANGE_NAME, "direct");
        // 下面将队列绑定到交换机
        /**
         * 第一个参数：队列的名字
         * 第二个参数：交换机的名字
         * 第三个参数：路由的这个key 路由模型下只有这个key和交换机的路由相同才能接受到消息
         */
        channel.queueBind(QUEUE_NAME, EXCHANGE_NAME, "xiaofeifei");
        // 申明一个消费者
        DefaultConsumer consumer = new DefaultConsumer(channel) {
            /**
             *
             * @param consumerTag ： 表示的是  消费者 唯一的标记
             * @param envelope：信封 : 消息的一个封装
             * @param properties：前面发送消息的时候 写入的键值对
             * @param body ：获取到的消息的内容
             * @throws IOException
             */
            @Override
            public void handleDelivery(String consumerTag, Envelope envelope, AMQP.BasicProperties properties, byte[] body) throws IOException {
                System.out.println("11接受到的消息是" + new String(body));
                /**
                 * 第一个参数是当前这条消息的标记
                 * 第二个参数是是否自动应答
                 */
                // channel.basicAck(envelope.getDeliveryTag(), false);
            }
        };
        // 将消费者和队列进行绑定
        /**
         * 第一个参数：队列的名字
         * 第二个参数：是否自动应答
         * 第三个参数是 消费者
         */
        channel.basicConsume(QUEUE_NAME, true, consumer);
    }
}

消费者2写法

查看示例

public class Consumer2 {

    /**
     * 申明了一个交换机的名字
     */
    private static final String EXCHANGE_NAME = "exchange_routing";
    /**
     * 声明与交换机绑定的这个队列的名字
     */
    private static final String QUEUE_NAME = "exchange_routing_que_2";

    public static void main(String[] args) throws Exception {
        // 第一步获取连接
        Connection connection = ConnectionUtils.getConnection();
        // 建立通道
        Channel channel = connection.createChannel();
        // 申明一个队列
        /**
         *第一个参数：队列的名字
         *第二个参数：是否持久化  ：这个数据 发送到队列去的时候 这个数据 是否要持久化到数据库中去
         *第三个参数：是否排外
         *           第一个意思：是否允许这个通道以外的 其他消费者来消费这个数据
         *           第二个意思：连接关闭之后  这个队列是否自动删除
         *第四个参数：是否自动删除
         *           表示的是 当最后一个连接退出的时候是否要删除这个队列
         *第五个参数：创建队列 付带的头的信息(TTL   死信队列)
         *
         */
        channel.queueDeclare(QUEUE_NAME, false, false, false, null);
        // 声明交换机
        channel.exchangeDeclare(EXCHANGE_NAME, "direct");
        // 下面将队列绑定到交换机
        /**
         * 第一个参数：队列的名字
         * 第二个参数：交换机的名字
         * 第三个参数：路由的这个key ,路由模型下只有这个key和交换机的路由相同才能接受到消息
         */
        channel.queueBind(QUEUE_NAME, EXCHANGE_NAME, "xiaodandan");
        // 申明一个消费者
        DefaultConsumer consumer = new DefaultConsumer(channel) {
            /**
             *
             * @param consumerTag ： 表示的是  消费者 唯一的标记
             * @param envelope：信封 : 消息的一个封装
             * @param properties：前面发送消息的时候 写入的键值对
             * @param body ：获取到的消息的内容
             * @throws IOException
             */
            @Override
            public void handleDelivery(String consumerTag, Envelope envelope, AMQP.BasicProperties properties, byte[] body) throws IOException {
                System.out.println("22接受到的消息是" + new String(body));
                /**
                 * 第一个参数是当前这条消息的标记
                 * 第二个参数是是否自动应答
                 */
                // channel.basicAck(envelope.getDeliveryTag(),false);
            }
        };
        // 将消费者和队列进行绑定
        /**
         * 第一个参数：队列的名字
         * 第二个参数：是否自动应答
         * 第三个参数是 消费者
         */
        channel.basicConsume(QUEUE_NAME, true, consumer);
    }
}