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

常州外贸公司网站建设广州网站优化关键词排名

news 2025/8/11 23:19:52
常州外贸公司网站建设,广州网站优化关键词排名,怎么找到外贸公司采购,网站建设朝阳写在前面 本文看下rabbit mq的基础概念以及使用。 1：简单介绍 为了不同进程间通信的解耦，出现了消息队列，为了规范消息队列的具体实现，Java制定了jms规范，这是一套基于接口的规范，因此是绑定语言的&…

写在前面

本文看下rabbit mq的基础概念以及使用。

1：简单介绍

为了不同进程间通信的解耦，出现了消息队列，为了规范消息队列的具体实现，Java制定了jms规范，这是一套基于接口的规范，因此是绑定语言的，即只能通过Java语言来实现和使用，与jms类似还有基于net的nms，这也是一套规范接口，只不过是基于.net开发语言的。不管是jms还是nms，它们都有一个通病，就是无法实现跨语言，这个时候amqp就应用而生了，可以将其理解为一种应用层的协议，构建在tcp之上，因此就可以实现跨语言的消息通信，参考下图：
在这里插入图片描述

amqp协议通信模型如下：
在这里插入图片描述

2：基础环境准备

2.1：服务安装

参考docker安装rabbitmq 。

2.2：创建Virtual host和用户

  • 创建virtual host
    在这里插入图片描述
  • 创建admin用户
    在这里插入图片描述
  • 设置admin权限
    在这里插入图片描述
    添加成功:
    在这里插入图片描述

3：正戏

本文主要看其提供的5种队列，如下图：
在这里插入图片描述

3.1：简单队列

简单队列就是一个生产者一个消费者的队列方式，如下图：
在这里插入图片描述

  • 生产消息：
public class SimpleSend {private final static String QUEUE_NAME = "q_test_01";public static void main(String[] argv) throws Exception {// 获取到连接以及mq通道Connection connection = ConnectionUtil.getConnection();// 从连接中创建通道Channel channel = connection.createChannel();// 声明（创建）队列channel.queueDeclare(QUEUE_NAME, false, false, false, null);// 消息内容String message = "Hello World come here!!!";channel.basicPublish("", QUEUE_NAME, null, message.getBytes());System.out.println(" [x] Sent '" + message + "'");//关闭通道和连接channel.close();connection.close();}
}

生产后：
在这里插入图片描述
点击q_test_01:
在这里插入图片描述

  • 消费消息
public class SimpleRecv {private final static String QUEUE_NAME = "q_test_01";public static void main(String[] argv) throws Exception {// 获取到连接以及mq通道Connection connection = ConnectionUtil.getConnection();// 从连接中创建通道Channel channel = connection.createChannel();// 声明队列channel.queueDeclare(QUEUE_NAME, false, false, false, null);// 定义队列的消费者QueueingConsumer consumer = new QueueingConsumer(channel);// 监听队列 true 这里使用自动确认，及消息消费默认消费成功，这种方式效率高，但是容易丢失消息// 如果某些场景允许部分消息丢失，但是要求执行效率，则可以考虑将该值设置为true，否则设置为false，即手动确认// 最周通过执行channel.basicAck(delivery.getEnvelope().getDeliveryTag(), false);完成手动确认，多一次网络通信channel.basicConsume(QUEUE_NAME, true, consumer);// 获取消息while (true) {QueueingConsumer.Delivery delivery = consumer.nextDelivery();String message = new String(delivery.getBody());System.out.println(" [x] Received '" + message + "'");}}
}

输出：

[INFO] --- exec-maven-plugin:3.1.0:exec (default-cli) @ rabbitmq-study ---[x] Received 'Hello World come here!!!'

在这里插入图片描述

3.2：work队列

一个生产者多个消费者，如下图：
在这里插入图片描述

work队列看起来和简单队列相比只是多起了几个消费者而已。

  • 生产者
public class WorkSend {private final static String QUEUE_NAME = "test_queue_work";public static void main(String[] argv) throws Exception {// 获取到连接以及mq通道Connection connection = ConnectionUtil.getConnection();Channel channel = connection.createChannel();// 声明队列channel.queueDeclare(QUEUE_NAME, false, false, false, null);for (int i = 0; i < 100; i++) {// 消息内容String message = "" + i;channel.basicPublish("", QUEUE_NAME, null, message.getBytes());System.out.println(" [x] Sent '" + message + "'");Thread.sleep(i * 10);}channel.close();connection.close();}
}
  • 消费者
public class WorkRecv {private final static String QUEUE_NAME = "test_queue_work";public static void main(String[] argv) throws Exception {// 获取到连接以及mq通道Connection connection = ConnectionUtil.getConnection();Channel channel = connection.createChannel();// 声明队列channel.queueDeclare(QUEUE_NAME, false, false, false, null);// 同一时刻服务器只会发一条消息给消费者// 该值设置为1，配合手动确认，则可以实现一条一条消费，确认一条后消费下一条，且多个消费者时谁的消费能力强，谁消费的消息多// 消费者之间消费消息不相互影响channel.basicQos(1);// 定义队列的消费者QueueingConsumer consumer = new QueueingConsumer(channel);// 监听队列，false表示手动返回完成状态，true表示自动channel.basicConsume(QUEUE_NAME, false, consumer);
//        channel.basicConsume(QUEUE_NAME, true, consumer);// 获取消息while (true) {QueueingConsumer.Delivery delivery = consumer.nextDelivery();String message = new String(delivery.getBody());System.out.println(" [y] Received '" + message + "'");//休眠Thread.sleep(10);// 返回确认状态，注释掉表示使用自动确认模式channel.basicAck(delivery.getEnvelope().getDeliveryTag(), false);}}
}

3.3：订阅模式

这种这种模式可以实现一个消息同时被多个消费者消费（广播），但是具体的实现需要依赖于交换器exchange，生产者端将消息发送到交换器，之后消费者端只需要将某个消息队列绑定到交换器，交换器会将消息发送到绑定的所有队列，消费者端就可以从队列中获取到对应的消息，但需要注意一个队列的消息还是只可以获取一次，如下图们：
在这里插入图片描述

  • 生产者端
public class SubscribeSend {private final static String EXCHANGE_NAME = "test_exchange_fanout111";public static void main(String[] argv) throws Exception {// 获取到连接以及mq通道Connection connection = ConnectionUtil.getConnection();Channel channel = connection.createChannel();// 声明exchangechannel.exchangeDeclare(EXCHANGE_NAME, "fanout");// 消息内容String message = "Hello World!";channel.basicPublish(EXCHANGE_NAME, "", null, message.getBytes());System.out.println(" [x] Sent '" + message + "'");channel.close();connection.close();}
}

消费者端2个：

public class SubscribeRecv {private final static String QUEUE_NAME = "test_queue_work1";private final static String EXCHANGE_NAME = "test_exchange_fanout111";public static void main(String[] argv) throws Exception {// 获取到连接以及mq通道Connection connection = ConnectionUtil.getConnection();Channel channel = connection.createChannel();// 声明队列channel.queueDeclare(QUEUE_NAME, false, false, false, null);// 绑定队列到交换机channel.queueBind(QUEUE_NAME, EXCHANGE_NAME, "");// 同一时刻服务器只会发一条消息给消费者channel.basicQos(1);// 定义队列的消费者QueueingConsumer consumer = new QueueingConsumer(channel);// 监听队列，手动返回完成channel.basicConsume(QUEUE_NAME, false, consumer);// 获取消息while (true) {QueueingConsumer.Delivery delivery = consumer.nextDelivery();String message = new String(delivery.getBody());System.out.println(" [Recv] Received '" + message + "'");Thread.sleep(10);channel.basicAck(delivery.getEnvelope().getDeliveryTag(), false);}}
}public class SubscribeRecv2 {private final static String QUEUE_NAME = "test_queue_work2";private final static String EXCHANGE_NAME = "test_exchange_fanout";public static void main(String[] argv) throws Exception {// 获取到连接以及mq通道Connection connection = ConnectionUtil.getConnection();Channel channel = connection.createChannel();// 声明队列channel.queueDeclare(QUEUE_NAME, false, false, false, null);// 绑定队列到交换机channel.queueBind(QUEUE_NAME, EXCHANGE_NAME, "");// 同一时刻服务器只会发一条消息给消费者channel.basicQos(1);// 定义队列的消费者QueueingConsumer consumer = new QueueingConsumer(channel);// 监听队列，手动返回完成channel.basicConsume(QUEUE_NAME, false, consumer);// 获取消息while (true) {QueueingConsumer.Delivery delivery = consumer.nextDelivery();String message = new String(delivery.getBody());System.out.println(" [Recv2] Received '" + message + "'");Thread.sleep(10);channel.basicAck(delivery.getEnvelope().getDeliveryTag(), false);}}
}

  • 启动2个消费者
    在这里插入图片描述

  • 启动生产者
    在这里插入图片描述

[INFO] --- exec-maven-plugin:3.1.0:exec (default-cli) @ rabbitmq-study ---[Recv2] Received 'Hello World!'[INFO] --- exec-maven-plugin:3.1.0:exec (default-cli) @ rabbitmq-study ---[Recv] Received 'Hello World!'

接着看下转换器和队列的绑定关系：
在这里插入图片描述

注意以下的问题：

1:因为交换器本身不具备数据存储的能力，所以如果是某个交换器上没有绑定任何的队列，则该消息将会丢失。
2:因为交换器本身不存储数据，所以在具体的消息队列绑定到交换器（即消费者启动前），不要生产消息到交换器，否则消息将会丢失。

3.4：路由模式

这种方式类似于订阅模式，也需要转换器作为中间商，但是并不会直接无脑的发送消息，而是会根据消费者额外指定的路由key，生产者在向转换器发送消息时会带着routeKey，消费者在消费消息时会指定自己期望的routeKey只有二者匹配时，才会从队列中消费对应的消息，l另外注意的时交换机类型设置为direct,如下图：
在这里插入图片描述

  • 生产者
public class RoutingSend {private final static String EXCHANGE_NAME = "test_exchange_direct123";public static void main(String[] argv) throws Exception {// 获取到连接以及mq通道Connection connection = ConnectionUtil.getConnection();Channel channel = connection.createChannel();// 声明exchange 设置交换器为direct，即路由模式channel.exchangeDeclare(EXCHANGE_NAME, "direct");// 消息内容String message = "Hello World!";// 设置路由key为"update"，即只有对应队列上设置了update路由key的消费者才会消费到消息channel.basicPublish(EXCHANGE_NAME, "update", null, message.getBytes());System.out.println(" [x] Sent '" + message + "'");channel.close();connection.close();}
}
  • 2个消费者
public class RoutingRecv {private final static String QUEUE_NAME = "test_queue_work_route";private final static String EXCHANGE_NAME = "test_exchange_direct123";public static void main(String[] argv) throws Exception {// 获取到连接以及mq通道Connection connection = ConnectionUtil.getConnection();Channel channel = connection.createChannel();// 声明队列channel.queueDeclare(QUEUE_NAME, false, false, false, null);// 绑定队列到交换机 设置路由key为delete，updatechannel.queueBind(QUEUE_NAME, EXCHANGE_NAME, "delete");channel.queueBind(QUEUE_NAME, EXCHANGE_NAME, "update");// 同一时刻服务器只会发一条消息给消费者channel.basicQos(1);// 定义队列的消费者QueueingConsumer consumer = new QueueingConsumer(channel);// 监听队列，手动返回完成channel.basicConsume(QUEUE_NAME, false, consumer);// 获取消息while (true) {QueueingConsumer.Delivery delivery = consumer.nextDelivery();String message = new String(delivery.getBody());System.out.println(" [x] Received '" + message + "'");Thread.sleep(10);channel.basicAck(delivery.getEnvelope().getDeliveryTag(), false);}}
}public class RoutingRecv2 {private final static String QUEUE_NAME = "test_queue_work_route2";private final static String EXCHANGE_NAME = "test_exchange_direct";public static void main(String[] argv) throws Exception {// 获取到连接以及mq通道Connection connection = ConnectionUtil.getConnection();Channel channel = connection.createChannel();// 声明队列channel.queueDeclare(QUEUE_NAME, false, false, false, null);// 绑定队列到交换机channel.queueBind(QUEUE_NAME, EXCHANGE_NAME, "delete");channel.queueBind(QUEUE_NAME, EXCHANGE_NAME, "insert");// 同一时刻服务器只会发一条消息给消费者channel.basicQos(1);// 定义队列的消费者QueueingConsumer consumer = new QueueingConsumer(channel);// 监听队列，手动返回完成channel.basicConsume(QUEUE_NAME, false, consumer);// 获取消息while (true) {QueueingConsumer.Delivery delivery = consumer.nextDelivery();String message = new String(delivery.getBody());System.out.println(" [x] Received '" + message + "'");Thread.sleep(10);channel.basicAck(delivery.getEnvelope().getDeliveryTag(), false);}}
}

在这里插入图片描述
在这里插入图片描述
先启动消费者再启动生产者测试可。
在这里插入图片描述

写在后面

参考文章列表

RabbitMQ使用教程(超详细)

docker安装rabbitmq

RabbitMq的一些概念，JMS、AMQP、MQ 。

http://www.tj-hxxt.cn/news/101322.html

相关文章：

  • 在哪个网站做一件代发靠谱杭州网站免费制作
  • php动态网站开发选修课考试朋友圈软文
  • 在百度做网站推广怎么做精准客源推广引流
  • 惠州做网站开发seo招聘要求
  • 网站建设学生选课系统设计关键词推广和定向推广
  • 医院网站怎么做前端培训班一般多少钱
  • 深圳响应式网站找哪里刷赞网站推广免费链接
  • 深圳网站建设微信开发哪有恶意点击软件买的
  • 自己做网站如何月入3k深圳债务优化公司
  • 做资源网站违法吗seo优化按天扣费
  • 做网站是不是要拍法人的照片建立网站的主要步骤
  • 苏州 网站设计 知名站长字体
  • 做网站页面提供的图结构网络软文发布平台
  • 微信如何做积分商城网站郑州网站建设优化
  • 西安市城市建设委员会官方网站淘宝关键词挖掘工具
  • 网站建设方案流程手机百度最新正版下载
  • 网站只显示一个网址官网seo优化
  • 网站 建站模式头条新闻今日头条
  • 专业做俄语网站建设司百度链接收录提交入口
  • 做公司网站需要免费网络推广软件
  • vc做网站北京seo顾问
  • 北京市建设集团有限公司宁波优化seo软件公司
  • 视频号视频怎么看下载链接win10优化大师免费版
  • 网站推广工作流程图百度收录查询工具官网
  • 个人网站模板html青岛网站建设制作推广
  • 做网站需要学些什么条件苏州优化排名seo
  • 网站标题作弊详解百度大数据查询怎么用
  • 帮别人做海报网站竞价推广怎样管理
  • 企业的网站设计中国十大网络销售公司
  • 手机网站引导页营销型网站外包