草庐IT

activemq

全部标签

java - 如何在 Windows 上将 ActiveMQ 安装为 64 位服务?

如何解决以下错误?有什么方法可以复制64位包装器吗?FATAL|wrapper|2011/01/0708:53:48|OpenSCManagerfailed-Accessisdenied.(0x5)STATUS|wrapper|2011/01/0708:54:13|ActiveMQinstalled.STATUS|wrapper|2011/01/0708:54:25|-->WrapperStartedasServiceSTATUS|wrapper|2011/01/0708:54:26|LaunchingaJVM...INFO|jvm1|2011/01/0708:54:26|Wrappe

redis - redis 或 activemq 等服务是否也具有高可用性?

我怀疑每项服务是否也具有高可用性。我想使用redis和activemq服务,我想避免单点故障。我还需要不断地向redis和activemq服务器写入数据。我找到了很多关于MySQL高可用的文章,但是关于其他数据库解决方案的文章很少,所以我的问题是是否有一个适用于许多产品的通用高可用解决方案套件? 最佳答案 Highavailability是CAPtheorem中的原则之一许多NoSQL数据库系统以牺牲数据一致性为代价来支持可用性。复制通常用于实现读取的高可用性,但写入可能取决于所使用的复制类型。尝试查看当前redisreplicat

redis - 如何在 Apache ActiveMQ 中只获取组中的最后一条消息?

场景:用户正在进行长时间的测验。每次互动后,我都会将当前分数和位置存储在测验中。我只想在数据库中存储用户在当前启动期间进行的最后交互。现在我通过Redis实现了这一点,每次我存储最后一次交互时我都会覆盖之前的交互。这能否通过Apache的ActiveMQ5.x实现,每个用户都可以将他的消息分组,而我只使用该组中收到的最后一条消息? 最佳答案 我不知道在ActiveMQ5.x中有任何自动执行此操作的方法,但您可以使用ActiveMQArtemis来执行此操作使用"lastvalue"queue.此功能允许您将消息的特殊属性设置为特定值

tcp - 我们可以配置 ActiveMQ 服务器的 TCP 级别负载平衡吗?

我正在使用ApacheCamel和ActiveMQ将消息路由到队列。为了获得高可用性,我们可以配置MQ服务器集群以防系统出现故障。ActiveMQ还提供故障转移功能。现在我想在TCP级别将两组MQ服务器负载平衡到单个IP:端口。故障转移功能能否对两个MQ服务器进行负载平衡?例如一个IP是负载平衡的。192.168.0.1:61616-->192.168.1.1:61616,192.168.1.2:61616 最佳答案 负载均衡可以通过ActiveMQ的“代理网络”功能来完成,参见http://activemq.apache.org/

java - 使用 Websocket 连接 stomp 和 ActiveMQ

我正在使用Stomp和ActiveMQ来监听来自局域网的消息并将其发布到某个应用程序。为了测试,我实现了使用tcp协议(protocol)连接,我需要使用Websocket协议(protocol)。我的activeMQ已经配置为使用WebSocket,看下面的代码:但是如果我使用ws连接对我不起作用:SimpleDateFormatsdf=newSimpleDateFormat("yyyy.MM.dd.HH:mm:ss.SSS");Stringuser=env("ACTIVEMQ_USER","admin");Stringpassword=env("ACTIVEMQ_PASSWORD"

activemq - 最大 MQTT 连接数

我需要创建一个可以处理5+百万个连接、5+百万个主题(每个客户端一个)、每秒处理30万条消息的服务器场。我试图了解各种消息代理的功能,因此我目前正在使用两个RHELEC2实例(r3.4xlarge)来获取大量可用资源。所以你不需要查找它,它有16vCPU,122GBRAM。我远未达到该使用限制。我无法超过600k的连接限制。由于客户端和服务器似乎都没有任何O/S限制(大量RAM/CPU等),限制我的是什么?我已经编辑/etc/security/limits.conf如下:*softnofile20000000*hardnofile20000000*softnproc20000000*h

java - 获取 ActiveMQ 队列长度的任何简单方法?

很难说出这里要问什么。这个问题模棱两可、含糊不清、不完整、过于宽泛或夸夸其谈,无法以目前的形式得到合理的回答。如需帮助澄清此问题以便重新打开,visitthehelpcenter.关闭10年前。如何使用Java在ActiveMQ中获取队列长度(发送到队列的未使用消息数)?

java - ActiveMQ:Openwire 对比 AMQP 对比 Stomp

ActiveMQ是一个消息代理,支持许多不同的协议(protocol),例如Openwire、AMQP和Stomp。真是让人一头雾水:在项目中使用Openwire和AMQP作为发送和接收消息的基础协议(protocol)有什么区别?这些协议(protocol)的优缺点是什么?是否可以在同一台机器上同时使用它们?是否有可能使用Stomp从浏览器发送消息并使用其他两种协议(protocol)在服务器中接收该消息? 最佳答案 对于1和2,也许这个页面有帮助:openwirevsamqp,Whichwouldperformbetter是的,

python - activemq 如何配置以在 python 中使用 stomp

我已经在本地安装并运行了activemq,但是当我运行以下脚本时,出现错误:#!/usr/bin/envpythonimporttimeimportsysimportstompclassMyListener(object):defon_error(self,headers,message):print'receivedanerror%s'%messagedefon_message(self,headers,message):print'receivedamessage%s'%messageconn=stomp.Connection(host_and_ports=[('localhost

performance - RabbitMQ/ActiveMQ 或 Redis 超过 250,000 msg/s

尽管redis和消息队列软件通常用于不同的目的,但我想问下使用redis的优缺点:一组事件收集器将传入消息写为键/值。消费者获取并删除处理过的key负载从100kmsg/s开始并在短时间内(例如几个月)超过250k目标是达到百万msg/s不严格要求持久性。在失败期间丢失非日志消息是可以的性能非常重要(因此,处理负载所需的系统数量)不必按消息到达的顺序处理消息您是否知道选择Redis而不是传统消息队列软件的用例?或者你会考虑别的吗?注意:我也看到了这个但没有帮助:Real-timeapplicationnewbie-Node.JS+RedisorRabbitMQ->client/serv