RabbitMQ入门案例之发布订阅模式

这篇具有很好参考价值的文章主要介绍了RabbitMQ入门案例之发布订阅模式。希望对大家有所帮助。如果存在错误或未考虑完全的地方,请大家不吝赐教,您也可以点击"举报违法"按钮提交疑问。

前言

本文章主要介绍RabbitMQ的发布订阅模式,该模式下,消息为广播形式,一经发布则会进入交换机绑定的队列中,详细介绍可以阅读官方文档。

官网文档地址:https://rabbitmq.com/getstarted.html

什么是发布与订阅模式

RabbitMQ中的发布与订阅模式是一种消息传递的方式,用于在分布式系统中传递消息。

在该模式中,发送者(发布者)通过将消息发送到一个称为Exchange(交换机)的组件,消息将被路由到一个或多个称为Queue(队列)的组件。每个队列都有一个名称和一组绑定(bindings),指定接收哪些消息。消费者(订阅者)可以在指定的队列上进行侦听,以获取消息。

该模式的一个重要特点是支持多个消费者接收相同的消息,通过使用多个队列和绑定实现。这种方式进一步提高了系统的可伸缩性和健壮性,从而能够满足大规模分布式系统对高效消息传递的需求。
RabbitMQ入门案例之发布订阅模式

代码实操

在实操之前,我们可以先到RabbitMQ的管理界面先定义好该模式的交换机与绑定交换机的消息队列。
定义交换机如下图:
RabbitMQ入门案例之发布订阅模式
然后点击All Exchange查看是否创建成功
RabbitMQ入门案例之发布订阅模式
点击定义好的交换机fanout_exchange,会出现下图中的界面:
RabbitMQ入门案例之发布订阅模式
这时我们就可以进行绑定队列了,下面是字段解释
RabbitMQ入门案例之发布订阅模式
在配置好queue消息后,点击绑定即可。
RabbitMQ入门案例之发布订阅模式
需要注意的是,我们绑定的队列是必须在Queue模块已经创建好的对列,不然是无法绑定的,也就是说,交换机和队列是两个分离开的模块,Exchange只负责将信息送到Queue中,而且Queue负责消息的存储和消费。

到这里交换机的工作就准备好了,接下来就是创建项目和导入依赖了。要使用RabbitMQ我们可以导入下面的这个依赖

<!--RabbitMQ依赖-->
<dependency>
	<groupId>com.rabbitmq</groupId>
	<artifactId>amqp-client</artifactId>
	<version>5.10.0</version>
</dependency>

生产者代码

public class Producer {
    public static void main(String[] args) {
        // 1: 创建连接工厂
        ConnectionFactory connectionFactory = new ConnectionFactory();
        // 2: 设置连接属性
        connectionFactory.setHost("IP地址");
        connectionFactory.setPort(端口号);
        connectionFactory.setVirtualHost("/");
        connectionFactory.setUsername("guest");
        connectionFactory.setPassword("guest");
        Connection connection = null;
        Channel channel = null;
        try {
            // 3: 从连接工厂中获取连接
            connection = connectionFactory.newConnection("生产者");
            // 4: 从连接中获取通道channel
            channel = connection.createChannel();
            // 6: 准备发送消息的内容
            String message = "宇宙无敌爱学习!!!";
            String  exchangeName = "fanout_exchange";
            String routingKey = "";
            // 7: 发送消息给中间件rabbitmq-server
            // @params1: 交换机exchange
            // @params2: 队列名称/routingkey
            // @params3: 属性配置
            // @params4: 发送消息的内容
            channel.basicPublish(exchangeName, routingKey, null, message.getBytes());
            System.out.println("消息发送成功!");
        } catch (Exception ex) {
            ex.printStackTrace();
            System.out.println("发送消息出现异常...");
        } finally {
            // 7: 释放连接关闭通道
            if (channel != null && channel.isOpen()) {
                try {
                    channel.close();
                } catch (Exception ex) {
                    ex.printStackTrace();
                }
            }
            if (connection != null) {
                try {
                    connection.close();
                } catch (Exception ex) {
                    ex.printStackTrace();
                }
            }
        }
    }
}

执行代码效果如下:RabbitMQ入门案例之发布订阅模式
我们到管理界面查看是否有消息被写入了,结果如下:
RabbitMQ入门案例之发布订阅模式
发现在这个模式下,三个队列都被放入了同一个消息,这就是所谓的发布与订阅,类似广播,一经发布就全部人都收到

接下来我执行生产者代码,生产者代码使用了线程来进行处理,代码如下:

public class Consumer {
    private static Runnable runnable = () -> {
        // 1: 创建连接工厂
        ConnectionFactory connectionFactory = new ConnectionFactory();
        // 2: 设置连接属性
        connectionFactory.setHost("IP地址");
        connectionFactory.setPort(端口号);
        connectionFactory.setVirtualHost("/");
        connectionFactory.setUsername("guest");
        connectionFactory.setPassword("guest");
        //获取队列的名称
        final String queueName = Thread.currentThread().getName();
        Connection connection = null;
        Channel channel = null;
        try {
            // 3: 从连接工厂中获取连接
            connection = connectionFactory.newConnection("生产者");
            // 4: 从连接中获取通道channel
            channel = connection.createChannel();
            // 5: 申明队列queue存储消息
            /*
             *  如果队列不存在,则会创建
             *  Rabbitmq不允许创建两个相同的队列名称,否则会报错。
             *
             *  @params1: queue 队列的名称
             *  @params2: durable 队列是否持久化
             *  @params3: exclusive 是否排他,即是否私有的,如果为true,会对当前队列加锁,其他的通道不能访问,并且连接自动关闭
             *  @params4: autoDelete 是否自动删除,当最后一个消费者断开连接之后是否自动删除消息。
             *  @params5: arguments 可以设置队列附加参数,设置队列的有效期,消息的最大长度,队列的消息生命周期等等。
             * */
            // 这里如果queue已经被创建过一次了,可以不需要定义
            //channel.queueDeclare("queue1", false, false, false, null);
            // 6: 定义接受消息的回调
            Channel finalChannel = channel;
            finalChannel.basicConsume(queueName, true, new DeliverCallback() {
                @Override
                public void handle(String s, Delivery delivery) throws IOException {
                    System.out.println(queueName + ":收到消息是:" + new String(delivery.getBody(), "UTF-8"));
                }
            }, new CancelCallback() {
                @Override
                public void handle(String s) throws IOException {
                }
            });
            System.out.println(queueName + ":开始接受消息");
            System.in.read();
        } catch (Exception ex) {
            ex.printStackTrace();
            System.out.println("发送消息出现异常...");
        } finally {
            // 7: 释放连接关闭通道
            if (channel != null && channel.isOpen()) {
                try {
                    channel.close();
                } catch (Exception ex) {
                    ex.printStackTrace();
                }
            }
            if (connection != null && connection.isOpen()) {
                try {
                    connection.close();
                } catch (Exception ex) {
                    ex.printStackTrace();
                }
            }
        }
    };
    public static void main(String[] args) {
        // 启动三个线程去执行
        new Thread(runnable, "queue1").start();
        new Thread(runnable, "queue2").start();
        new Thread(runnable, "queue3").start();
    }
}

结果如下:
RabbitMQ入门案例之发布订阅模式RabbitMQ入门案例之发布订阅模式
可以看出,消息被消费掉了。文章来源地址https://www.toymoban.com/news/detail-487865.html

以上便是发布与订阅的全部内容,仅作为个学习笔记使用
感谢观看

到了这里,关于RabbitMQ入门案例之发布订阅模式的文章就介绍完了。如果您还想了解更多内容,请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章,希望大家以后多多支持TOY模板网!

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处: 如若内容造成侵权/违法违规/事实不符,请点击违法举报进行投诉反馈,一经查实,立即删除!

领支付宝红包 赞助服务器费用

相关文章

觉得文章有用就打赏一下文章作者

支付宝扫一扫打赏

博客赞助

微信扫一扫打赏

请作者喝杯咖啡吧~博客赞助

支付宝扫一扫领取红包,优惠每天领

二维码1

领取红包

二维码2

领红包