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

return机制的主要作用就是监听不可达的消息(没人要的消息)

生产者写法示例：

public class Producer {

    /**
     * 交换机的名字
     */
    private static final String EXCHANGE_NAME = "exchange_return_test";

    public static void main(String[] args) throws Exception {
        // 获取连接
        Connection connection = ConnectionUtils.getConnection();
        // 创建通道
        Channel channel = connection.createChannel();

        // 设置return机制的监听
        channel.addReturnListener(new ReturnListener() {
            @Override
            public void handleReturn(int i, String s, String s1, String s2, AMQP.BasicProperties basicProperties, byte[] bytes) throws IOException {
                // 如果执行到了这里 说明这个消息是找不到地方去的
                System.out.println("当前消息找不到地方去了" + new String(bytes));
            }
        });

        // 需要申明咋们的交换机
        /**
         * 第一个参数：交换机的名字
         * 第二个参数：交换机的类型  这里要注意  路由模型的话 这里的类型是不能乱写的 direct
         */
        channel.exchangeDeclare(EXCHANGE_NAME, "direct");

        // 接下来发送数据到交换机
        /**
         * 第一个参数：交换机的名字
         * 第二个参数：路由的key
         * 第三个参数：如果是使用 return 机制的话，需要设置为 true
         * 第四个参数：发送消息的时候  附带的一些属性信息
         * 第五个参数：发送的这个消息体的内容
         */
        for (int i = 0; i < 10; i++) {
            channel.basicPublish(EXCHANGE_NAME, "oooo", true, null, ("路由模型的参数" + i).getBytes());
        }
    }
}