面试中经常问道的问题一

ActiveMQ持久订阅设置


在JMS中,Topic实现publish和subscribe语义。一条消息被publish时,它将发到所有感兴趣的订阅者,所以零到多个subscriber将接收到消息的一个拷贝。但是在消息代理接收到消息时,只有激活订阅的subscriber能够获得消息的一个拷贝。
    JMS Queue执行load balancer语义。一条消息仅能被一个consumer收到。如果在message发送的时候没有可用的consumer,那么它将被保存一直到能处理该message的consumer可用。如果一个consumer收到一条message后却不响应它,那么这条消息将被转到另一个consumer那儿。一个Queue可以有很多consumer,并且在多个可用的consumer中负载均衡
1    queue与topic的技术特点对比
 
Topic    Queue
概要    Publish Subscribe messaging 发布订阅消息    Point-to-Point 点对点
有无状态    topic数据默认不落地，是无状态的。    Queue数据默认会在mq服务器上以文件形式保存，比如Active MQ一般保存在$AMQ_HOME\data\kr-store\data下面。也可以配置成DB存储。
完整性保障    并不保证publisher发布的每条数据，Subscriber都能接受到。    Queue保证每条数据都能被receiver接收。
消息是否会丢失    一般来说publisher发布消息到某一个topic时，只有正在监听该topic地址的sub能够接收到消息；如果没有sub在监听，该topic就丢失了。    Sender发送消息到目标Queue，receiver可以异步接收这个Queue上的消息。Queue上的消息如果暂时没有receiver来取，也不会丢失。
消息发布接收策略    一对多的消息发布接收策略，监听同一个topic地址的多个sub都能收到publisher发送的消息。Sub接收完通知mq服务器    一对一的消息发布接收策略，一个sender发送的消息，只能有一个receiver接收。receiver接收完后，通知mq服务器已接收，mq服务器对queue里的消息采取删除或其他操作。
          Topic和queue的最大区别在于topic是以广播的形式，通知所有在线监听的客户端有新的消息，没有监听的客户端将收不到消息；而queue则是以点对点的形式通知多个处于监听状态的客户端中的一个。


ActiveMQ持久订阅设置

通过为发布者设置 PERSISTENT传送模式，为订阅者时使用持久订阅，这样可以保证 Pub/Sub 程序接收所有发布的消息。 
消息订阅分为非持久订阅(non-durable subscription)和持久订阅(durable subscription)，非持久订阅只有当客户端处于激活状态，也就是和 ActiveMQ 保持连接状态才能收到发送到某个主题的消息，而当客户端处于离线状态，这个时间段发到主题的消息将会丢失，永远不会收到。持久订阅时，客户端向ActiveMQ 注册一个识别自己身份的 ID，当这个客户端处于离线时，ActiveMQ会为这个 ID 保存所有发送到主题的消息，当客户端再次连接到ActiveMQ 时， 会根据自己的 ID 得到所有当自己处于离线时发送到主题的消息。持久订阅会增加开销，同一时间在持久订阅中只有一个激活的用户。 建立持久订阅的步骤： 
1． 为连接设置一个客户 ID； 
2． 为订阅的主题指定一个订阅名称； 
上述组合必须唯一。 
代码实现持久化订阅

（1）使用queue，即队列时，每个消息只有一个消费者，所以，持久化很简单，只要保存到数据库即可

。然后，随便一个消费者取走处理即可。某个消费者关掉一阵子，也无所谓。

（2）使用topic，即订阅时，每个消息可以有多个消费者，就麻烦一些。

首先，假设消费者都是普通的消费者，
------------------------
<1>activemq启动后，发布消息1，可惜，现在没有消费者启动着，也就是没有消费者进行了订阅。那么

，这个消息就被抛弃了。

<2>消费者1启动了，连接了activemq，进行了订阅，在等待消息~~

activemq发布消息2，OK，消费者1收到，并进行处理。消息抛弃。

<3>消费者2也启动了，连接了activemq，进行了订阅，在等待消息~~

activemq发布消息3，OK，消费者1，消费者2都收到，并进行处理。消息抛弃。

<4>消费者1关掉了。

activemq发布消息4，OK，消费者2收到，并进行处理。消息抛弃。

<5>消费者1又启动了。

activemq发布消息5，OK，消费者1，消费者2都收到，并进行处理。消息抛弃。
-----------------------------
总结一下：
activemq只是向当前启动的消费者发送消息。
关掉的消费者，会错过很多消息，并无法再次接收这些消息。

如果发送的消息是重要的用户同步数据，错过了，用户数据就不同步了。

那么，如何让消费者重新启动时，接收到错过的消息呢？

答案是持久订阅。
-----------------------------

普通的订阅，不区分消费者，场地里有几个人头，就扔几个馒头。
持久订阅，就要记录消费者的名字了。
张三说，我是张三，有馒头给我留着，我回来拿。
李四说，我是李四，有馒头给我留着，我回来拿。
activemq就记下张三，李四两个名字。

那么，分馒头时，还是一个人头给一个馒头。
分完了，一看张三没说话，说明他不在，给他留一个。
李四说话了，那就不用留了。

张三回来了，找activemq，一看，这不张三吧，快把他的馒头拿来。
可能是一个馒头，也可能是100个馒头，就看张三离开这阵子，分了多少次馒头了。

activemq区分消费者，是通过clientID和订户名称来区分的。
-----------------------------
// 创建connection
connection = connectionFactory.createConnection();
connection.setClientID("bbb"); //持久订阅需要设置这个。
connection.start();

// 创建session
Session session = connection.createSession(false,Session.AUTO_ACKNOWLEDGE);

// 创建destination
Topic topic = session.createTopic("userSyncTopic"); //Topic名称

//MessageConsumer consumer = session.createConsumer(topic); //普通订阅
MessageConsumer consumer = session.createDurableSubscriber(topic,"bbb"); //持久订阅


还有一点，消息的生产者，发送消息时用使用持久模式
MessageProducer producer = ...;
producer.setDeliveryMode(DeliveryMode.PERSISTENT);
不设置，默认就是持久的

（5）使用相同的“clientID”，则认为是同一个消费者。两个程序使用相同的“clientID”，则同时只能有一个连接到activemq，第二个连接的会报错。

（6）activemq的设置在conf/activemq.xml中，默认消息是保存在data/kahadb中，重启activemq消息不会丢。

可以访问http://localhost:8161/admin/index.jsp：查看当前的队列、Topic和持久订户的信息、发送消息等等，很方便。

可以复制activemq-jdbc.xml中的内容过来，修改一下，就可以把消息保存在其它数据库中了。

系统启动卡顿的解决办法
 <!-- 这个amq的标签因为本地没有,每次都要去线上找,所以导致系统启动卡住 -->
    <!-- <amq:connectionFactory id="amqConnectionFactory"
        brokerURL="tcp://localhost:61616" userName="admin" password="admin"  /> -->
        
    <!-- 另外一种解决办法 -->
    <bean id="amqConnectionFactory" class="org.apache.activemq.ActiveMQConnectionFactory">
        <property name="brokerURL" value="tcp://localhost:61616"></property>
        <property name="userName" value="admin"></property>
        <property name="password" value="admin"></property>
    </bean>
 

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/news/118769.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

C使用const详细（学习笔记）

C使用const详细（学习笔记）

1、对形参使用const&#xff0c;告诉编译器&#xff0c;该函数不能修改arr指向的数组中的内容。 int sum(const int * arr,int n);2、指向const的指针不能用于改变值 3、把const数据或非const数据的地址初始化为只想const的指针或为其赋值时合法的 //带const的指针&#xff0…
阅读更多...
景联文科技提供4D-BEV标注工具：提升自动驾驶感知能力的精准数据支持

景联文科技提供4D-BEV标注工具：提升自动驾驶感知能力的精准数据支持

4D-BEV标注是一种用于自动驾驶领域的数据标注方法。在3D空间的基础上&#xff0c;加入了时间维度&#xff0c;形成了四个维度。这种方法通过精准地跟踪和记录动态对象&#xff08;如车辆、行人&#xff09;的运动轨迹、姿势变化以及速度等信息&#xff0c;全面理解和分析动态对…
阅读更多...
【Python机器学习】零基础掌握DictVectorizer特征提取

【Python机器学习】零基础掌握DictVectorizer特征提取

如何有效地处理和转换非数值型的数据，以便能够用于机器学习模型？ 在实际生活中，特别是在数据分析和机器学习领域，经常会遇到需要处理的数据并不都是数值型的。比如在电商网站的用户行为分析中，可能会记录用户的性别、购买产品类型、支付方式等信息。这些数据中有些是分类…
阅读更多...
avaScript 条件分支语句以及示例和详细代码解释为什么这样写呢（1）

avaScript 条件分支语句以及示例和详细代码解释为什么这样写呢（1）

在JavaScript中&#xff0c;条件分支语句主要有if语句、else if语句和else语句。条件分支语句用于根据不同的条件执行不同的代码块。下面是一个使用条件分支语句的示例代码&#xff1a; javascript let num 10;if (num > 0) {console.log("num是一个正数"); } e…
阅读更多...
Java中JVM、JRE和JDK三者有什么区别和联系？

Java中JVM、JRE和JDK三者有什么区别和联系？

任何语言或者软件的运行都需要环境。就像人要生活在空气中&#xff0c;鱼要活在水中&#xff0c;喜阴植物就不能放在阳光下暴晒一样&#xff0c;任何对象个体的存在都离不开其所需要的环境&#xff0c;编程语言亦是一样的。 java 语言的开发运行&#xff0c;也离不开 Java 语言…
阅读更多...
vue中前端导出excel的两种方法

vue中前端导出excel的两种方法

vue中前端导出excel方法 其实前端导出和后端导出的处理方式很类似 我们这样主要是根据后端接口返回的不分页的列表来进行整体导出功能的实现 依赖文件 可以直接cv到项目中 utils下的 Export2Excel.js文件 require(script-loader!file-saver); require(script-loader!xlsx/d…
阅读更多...
crossover23.6闪亮登场发布啦，2023最新功能解析

crossover23.6闪亮登场发布啦，2023最新功能解析

CrossOver刚刚更新了23.6版本&#xff0c;新增了多款游戏的支持&#xff0c;快来看看你想玩的游戏在不在里面吧。点击这里立即下载最新版CrossOver。 软件介绍 CrossOver 23.6 让Mac可以运行Windows程序的工具 已通过小编安装运行测试 100%可以使用。 CrossOver for Mac 23.…
阅读更多...
OKLink携手CertiK在港举办Web3生态安全主题论坛

OKLink携手CertiK在港举办Web3生态安全主题论坛

2023年10月23日&#xff0c;OKLink与CertiK共同发起的Web3生态安全主题论坛在香港铜锣湾拉开帷幕。本次论坛由OKLink和CertiK主办&#xff0c;香港投资推广署独家支持&#xff0c;聚焦如何构建安全可靠的Web3生态系统议题&#xff0c;同时深入剖析这一进程中所面临的潜在挑战。…
阅读更多...
企事业单位/公司电脑文件透明加密保护 | 防泄密软件\系统！

企事业单位/公司电脑文件透明加密保护 | 防泄密软件\系统！

推荐——「天锐绿盾电脑文件防泄密系统」 一款全面的企业/公司数据透明加密防泄密系统&#xff0c;旨在从源头上保障数据的安全和使用安全。 PC访问地址&#xff1a; https://isite.baidu.com/site/wjz012xr/2eae091d-1b97-4276-90bc-6757c5dfedee 它具有以下特点&#xff1a…
阅读更多...
第6周 .NET

第6周 .NET

好嘛&#xff01;本来以为上周SQL Server环境配置等已经够恶心了&#xff0c;没想到这周又得去搞所谓的Microsoft Visual Studio 2005了。 首先非常离谱的是&#xff0c;这个Microsoft Visual Studio 2005如果就是指Visual Studio 2005&#xff0c;那么已经是8年前的老的不行的…
阅读更多...
TensorFlow图像多标签分类实例

TensorFlow图像多标签分类实例

接下来&#xff0c;我们将从零开始讲解一个基于TensorFlow的图像多标签分类实例&#xff0c;这里以图片验证码为例进行讲解。 在我们访问某个网站的时候&#xff0c;经常会遇到图片验证码。图片验证码的主要目的是区分爬虫程序和人类&#xff0c;并将爬虫程序阻挡在外。 下面…
阅读更多...
Python超入门（6）__迅速上手操作掌握Python

Python超入门（6）__迅速上手操作掌握Python

# 26.函数和参数 # 注意&#xff1a;有参函数和无参函数的名字要不同 def user(): # 无参函数print("hello world!")def user1(my_id): # 有参函数print(my_id)def user2(first_name, last_name): # 有参函数print(fMy name is {first_name} {last_name})print(&…
阅读更多...
【机器学习】迁移学习（Transfer）详解！

【机器学习】迁移学习（Transfer）详解！

1. 什么是迁移学习 迁移学习(Transfer Learning)是一种机器学习方法&#xff0c;就是把为任务 A 开发的模型作为初始点&#xff0c;重新使用在为任务 B 开发模型的过程中。迁移学习是通过从已学习的相关任务中转移知识来改进学习的新任务&#xff0c;虽然大多数机器学习算法都是…
阅读更多...
微信小程序云开发笔记-初始化商城小程序

微信小程序云开发笔记-初始化商城小程序

缘起&#xff1a;由于痴迷机器人&#xff0c;店都快倒闭了&#xff0c;没办法&#xff0c;拿出点精力搞一下店里的小程序&#xff0c;要多卖货才能活下来搞机器人&#xff0c;在此记录一下搞小程序的过程&#xff0c;要不然搞完又忘了。腾讯的云开发&#xff0c;前端和后端都有…
阅读更多...
改变光标形状的多种方式

改变光标形状的多种方式

一&#xff0c;用css的方式进行添加属性&#xff1a; #div{cursor:pointer; } 二&#xff0c;使用js的方式改变光标的状态&#xff1a; 1 // 使用在元素的标签上的事件 2 // 第一种方式 3 onmouseover"this.style.cursormouseHand" 4 5 // 第二种方式 6 onmouseo…
阅读更多...
Linux阻塞IO（高级字符设备二）

Linux阻塞IO（高级字符设备二）

阻塞IO属于同步 IO&#xff0c;阻塞IO在Linux内核中是非常常用的 IO 模型&#xff0c;所依赖的机制是等待队列。 一、等待队列介绍 在 Linux 驱动程序中&#xff0c;阻塞进程可以使用等待队列来实现。等待队列是内核实现阻塞和唤醒的内核机制&#xff0c;以双循环链表为基础结…
阅读更多...
C笔记：引用调用，通过指针传递

C笔记：引用调用，通过指针传递

代码 #include<stdio.h> int max1(int num1,int num2) {if(num1 < num2){num1 num2;}else{num2 num1;} } int max2(int *num1,int *num2) {if(num1 < num2){*num1 *num2; // 把 num2 赋值给 num1 }else{*num2 *num1;} } int main() {int num1 0,num2 -2;int…
阅读更多...
SLAM从入门到精通（三边测量法详解）

SLAM从入门到精通（三边测量法详解）

【 声明&#xff1a;版权所有&#xff0c;欢迎转载&#xff0c;请勿用于商业用途。 联系信箱&#xff1a;feixiaoxing 163.com】 三边测量&#xff0c;或者说叫三角定位&#xff0c;是定位系统中很常见的一种测量方法。它最主要的原理就是依靠已有的三个特征坐标和半径&#xf…
阅读更多...
Windows10系统安装telnet命令

Windows10系统安装telnet命令

简介 telnet命令可以测试目标服务器端口是否开通&#xff0c;使用命令 telnet ip地址 端口&#xff0c;输入命令后回车&#xff0c;如果进入输入状态&#xff0c;则表示目标服务器端口已开通&#xff0c;可以通过外网访问 Windows10系统安装步骤 1.打开控制面板 2.选择程序…
阅读更多...
Hadoop3教程（三十一）：（生产调优篇）异构存储

Hadoop3教程（三十一）：（生产调优篇）异构存储

文章目录 &#xff08;157&#xff09;异构存储概述概述异构存储的shell操作 &#xff08;158&#xff09;异构存储案例实操参考文献 &#xff08;157&#xff09;异构存储概述 概述 异构存储&#xff0c;也叫做冷热数据分离。其中&#xff0c;经常使用的数据被叫做是热数据&…
阅读更多...
最新文章

Copyright @ 2022~2023