当前位置: 首页 > news >正文

翰诺网站建设搜索引擎优化特点

翰诺网站建设,搜索引擎优化特点,网站专题策划页面怎么做,ps网站如何做烫金的文字这篇文章,主要介绍RabbitMQ消息队列中七种模式里面最简单的使用模式。 目录 一、消息队列的使用 1.1、消息队列七种模式 1.2、最简单的模式使用 (1)引入依赖 (2)编写生产者 (3)编写消费者…

这篇文章,主要介绍RabbitMQ消息队列中七种模式里面最简单的使用模式。

目录

一、消息队列的使用

1.1、消息队列七种模式

1.2、最简单的模式使用

(1)引入依赖

(2)编写生产者

(3)编写消费者


一、消息队列的使用

1.1、消息队列七种模式

RabbitMQ官方提供了七种消息队列的使用方式,分别如下所示:

  • 最简单的模式:最简单的模式就是生产者直接向消息队列发生消息,然后消费者从消息队列消费消息。
  • 工作队列模式:这支持一个消息队列允许多个消费者同时进行消费,相当于是多线程并发消费,默认是采用轮询的策略分发消息。
  • 发布订阅模式:这里就需要引入Exchange交换机了,每一个消息队列可以订阅这个Exchange交换机,当交换机接收到消息之后,会将这个一条消息发布到所有订阅的消息队列里面。
  • 路由模式:路由模式允许消息队列从Exchange交换机里面接收指定RouteKey路由键的消息,不是这个路由键的消息将不会被分发到消息队列里面。
  • 主题模式:这可以将一类消息全部分发到指定的消息队列里面,并且Topics模式支持通配符指定RouteKey路由键。
  • RPC模式:这种模式我没怎么学习。
  • 发布确认模式:这种模式是为了保证生产者发送的消息一定能够到达RabbitMQ里面的一种方式,是解决消息丢失问题的。

1.2、最简单的模式使用

最简单的模式,只有一个消息队列,生成者向指定的消息队列里面发送消息,然后消费者从指定的消息队列里面消费消息。

注意:需要启动RabbitMQ消息队列服务哦,不然运行代码会报错。

(1)引入依赖

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

(2)编写生产者

package com.rabbitmq.demo.simple;import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;/*** @version 1.0.0* @Date: 2023/2/25 16:23* @Copyright (C) ZhuYouBin* @Description: 消息生产者*/
public class Producer {public static void main(String[] args) {// 1、创建连接工厂ConnectionFactory factory = new ConnectionFactory();// 2、设置连接的 RabbitMQ 服务地址factory.setHost("127.0.0.1"); // 默认就是本机factory.setPort(5672); // 默认就是 5672 端口// 3、获取连接Connection connection = null; // 连接Channel channel = null; // 通道try {connection = factory.newConnection();// 4、获取通道channel = connection.createChannel();// 5、指定需要操作的消息队列,如果队列不存在,则会创建channel.queueDeclare("queue_demo_2023", false, false, false, null);// 6、发送消息String message = "这是最简单的模式,发送的消息数据";channel.basicPublish("", "queue_demo_2023", null, message.getBytes());} catch (Exception e) {e.printStackTrace();} finally {if (null != channel) {try {channel.close();} catch (Exception e) {}}if (null != connection) {try {connection.close();} catch (Exception e) {}}}}
}

运行上面的生产者代码,查看RabbitMQ控制台,可以发现此时有一条消息啦。

(3)编写消费者

package com.rabbitmq.demo.simple;import com.rabbitmq.client.*;import java.io.IOException;/*** @version 1.0.0* @Date: 2023/2/25 16:30* @Copyright (C) ZhuYouBin* @Description: 消息消费者*/
public class Consumer {public static void main(String[] args) {// 1、创建连接工厂ConnectionFactory factory = new ConnectionFactory();// 2、设置连接的 RabbitMQ 服务地址factory.setHost("127.0.0.1"); // 默认就是本机factory.setPort(5672); // 默认就是 5672 端口// 3、获取连接Connection connection = null; // 连接Channel channel = null; // 通道try {connection = factory.newConnection();// 4、获取通道channel = connection.createChannel();// 5、指定需要操作的消息队列,如果队列不存在,则会创建channel.queueDeclare("queue_demo_2023", false, false, false, null);// 6、消费消息DeliverCallback callback = new DeliverCallback() {public void handle(String s, Delivery delivery) throws IOException {// 接收消息System.out.println("这是接收的消息:" + new String(delivery.getBody()));}};channel.basicConsume("queue_demo_2023", true, callback, i->{});} catch (Exception e) {e.printStackTrace();}}
}

运行消费者代码,查看控制台输出,以及RabbitMQ控制界面,可以发现,此时消息队列中的消息不存在了。

到这里,RabbitMQ最简单的消息发送和消费就完成啦。

综上,这篇文章结束了,主要介绍RabbitMQ消息队列中七种模式里面最简单的使用模式。

http://www.yidumall.com/news/14674.html

相关文章:

  • 最专业的企业营销型网站建设公司免费建自己的网址
  • 工商管理网站nba最新排名公布
  • 中国人做网站卖美国人怎么优化整站
  • easyui网站开发实战 pdf品牌推广方案
  • 韩国儿童才艺网站建设模板网络运营
  • wap网站开发平台2023年又封城了
  • 周末游做的好的网站微信营销是什么
  • wordpress页脚小工具栏排名优化关键词公司
  • 哪个网站做老款二手车seo优化知识
  • 国内最新经济新闻刷移动端seo软件
  • 网络公司网站绪论优秀的网页设计网站
  • 上海营销型网站设计希爱力
  • 武汉网站建设企业福州关键词排名软件
  • 织梦系统网站搭建教程百度手机版网址
  • 网页设计代码大全下载公司seo是指什么意思
  • 企业建网站百度竞价排名医院事件
  • 舟山网站建设seo培训学校机构
  • 网站内页设置多少个关键字最好seo是什么缩写
  • 关于做公司app的软件或网站外贸高端网站设计公司
  • 网站详情页怎么做的外贸seo站
  • 网购网站开发流程图关键词在线试听
  • 个人网站做淘宝客违规seo怎么快速提高排名
  • 淄博专业网站建设哪家专业网站推广的一般流程是
  • 做公司网站的2022年seo最新优化策略
  • 苏州新区网站制作公司昆山网站建设公司
  • 互联网站建设机构谷歌推广优化
  • 北京好网站制作公司什么是seo网站优化
  • 商务网站规划与建设课程设计辅导机构
  • 深圳网站网站开发长春网站关键词推广
  • 石河子市住房和城乡建设局网站搜索引擎查重