其他分享
首页 > 其他分享> > 消息队列---RabbitMQ的学习(六)

消息队列---RabbitMQ的学习(六)

作者:互联网

 苦心人,天不负,卧薪尝胆,三千越甲可吞吴

Success

自述

    RabbitMQ的第五个场景------主题(topic),基于路由之上,该文章可以相对简洁,因为它是基于路由之上,实际上就是将交换机的类型进行改变。
在这里插入图片描述

Exchange类型描述

扇出(fanout):发布/订阅场景中使用,将消息无条件推送给已绑定的队列。
直接(direct):路由场景中使用,将消息推送给满足条件已绑定的队列,用于精准匹配。
主题(topic):路由场景中使用,将消息推送给满足条件已绑定的队列,用于模糊匹配。
注意:交换机类型在某个场景下都可以任意使用,不存在固定场景固定类型。

主题场景模型解析

    在发布/订阅场景下的时候,交换机设置的类型是扇出(fanout),但并没有一点灵活性,只是一味的无脑传递消息,在路由场景下的时候,交换机设置的类型是直接(direct),虽然做到了对消息的限制,但是还是存在局限性-----不能基于多个标准进行路由,所以在路由的基础之上,我们再次改变交换机的类型,实现主题场景。
                               在这里插入图片描述在这里插入图片描述

主题场景

*:星号代表一个词或一个匹配项。
#:井号代表n个匹配项。
①当为“#”符号的时候,就类似于交换机的扇出(fanout)类型。
②当为“*”符号的时候,就类似于交换机的直接(direct)类型。
③当一个路由键中满足多个类型的时候,是无法与多个类型匹配的,只会匹配第一个类型。
④路由键可以为任意字,最大长度为255个字节,当路由键不在跟符号“*”或“#”符号的话,那么它的匹配方式就会和路由完全一致。

 ExSend.java

/**
 * //第五个场景:主题
 * 生产者
 */
public class ExSend {
    //exchangename
    private static final String EX_CHANGENAME = "ex_name1";

    public static void main(String[] args) {
        try {
            //1.connection
            Connection connection = ConnectionUtil.getConnection();
            //2.channel
            Channel channel = connection.createChannel();
            //3.exchange
            //paramone:exchangename
            //paramtwo:exchangetype ---->topic主题
            channel.exchangeDeclare(EX_CHANGENAME, "topic");
            //sendtype
            String[] sendtype = new String[]{"frog.consumer1", "Elephant.consumer1", "frog", "lion", "lion.consumer1", "lion.frog.Elephant.frog"};
            for (int i = 0; i < sendtype.length; i++) {
                channel.basicPublish(EX_CHANGENAME, sendtype[i], null, (sendtype[i] + "=====msg send suc").getBytes());
            }
            System.out.println("消息发送成功");

        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

 ExRecv.java

/**
 * topic
 * 青蛙系列消费者
 */
public class ExRecv {

    //exchangename
    private static final String EX_CHANGENAME = "ex_name1";

    public static void main(String[] args) {
        try {
            //1.connection
            Connection connection = ConnectionUtil.getConnection();
            //2.channel
            Channel channel = connection.createChannel();
            //3.exchange
            //paramone:exchangename
            //paramtwo:exchangetype ---->topic主题
            channel.exchangeDeclare(EX_CHANGENAME, "topic");
            //4.queue
            String queue = channel.queueDeclare().getQueue();
            //5.binding
            channel.queueBind(queue, EX_CHANGENAME, "frog.#");
            //6.get msg
            DeliverCallback deliverCallback = new DeliverCallback() {
                @Override
                public void handle(String s, Delivery delivery) throws IOException {
                    System.out.println(new String(delivery.getBody()));
                }
            };
            //7.consumer
            channel.basicConsume(queue, true, deliverCallback, cancel -> {
            });
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

 ExRecv2.java

/**
 * topic
 * 大象系列消费者
 */
public class ExRecv2 {

    //exchangename
    private static final String EX_CHANGENAME = "ex_name1";

    public static void main(String[] args) {
        try {
            //1.connection
            Connection connection = ConnectionUtil.getConnection();
            //2.channel
            Channel channel = connection.createChannel();
            //3.exchange
            //paramone:exchangename
            //paramtwo:exchangetype ---->topic主题
            channel.exchangeDeclare(EX_CHANGENAME, "topic");
            //4.queue
            String queue = channel.queueDeclare().getQueue();
            //5.binding
            channel.queueBind(queue, EX_CHANGENAME, "Elephant.#");
            //6.get msg
            DeliverCallback deliverCallback = new DeliverCallback() {
                @Override
                public void handle(String s, Delivery delivery) throws IOException {
                    System.out.println(new String(delivery.getBody()));
                }
            };
            //7.consumer
            channel.basicConsume(queue, true, deliverCallback, cancel -> {
            });
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

 ExRecv3.java

/**
 * topic
 * 狮子系列消费者
 */
public class ExRecv3 {

    //exchangename
    private static final String EX_CHANGENAME = "ex_name1";

    public static void main(String[] args) {
        try {
            //1.connection
            Connection connection = ConnectionUtil.getConnection();
            //2.channel
            Channel channel = connection.createChannel();
            //3.exchange
            //paramone:exchangename
            //paramtwo:exchangetype ---->topic主题
            channel.exchangeDeclare(EX_CHANGENAME, "topic");
            //4.queue
            String queue = channel.queueDeclare().getQueue();
            //5.binding
            channel.queueBind(queue, EX_CHANGENAME, "lion.#");
            //6.get msg
            DeliverCallback deliverCallback = new DeliverCallback() {
                @Override
                public void handle(String s, Delivery delivery) throws IOException {
                    System.out.println(new String(delivery.getBody()));
                }
            };
            //7.consumer
            channel.basicConsume(queue, true, deliverCallback, cancel -> {
            });
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}


在这里插入图片描述
在这里插入图片描述

Ending

      加油,每天进步一点点!

标签:topic,String,队列,RabbitMQ,---,connection,CHANGENAME,EX,channel
来源: https://blog.csdn.net/qq_42618394/article/details/117884155