如何使用Stomp和ActiveMQ(和Perl)进行交易？
如何使用 Stomp 和 ActiveMQ (和 Perl) 进行交易？
概念与分类
Stomp 和 ActiveMQ 分别是一种基于代理的 Java 开源消息总线，以及一个消息代理。它们通常用于在分布式系统中实现生产者与消费者之间的通信。
优势
- Stomp：
- 支持多种消息格式，如 XML、JSON 和长连接。
- 可通过多种传输方式（如 TCP、Websocket 等）进行连接。
- 提供客户端和服务器端的简单、高效的二进制编解码。
- 易于集成，支持多种编程语言。
- ActiveMQ：
- 提供基于 JMS（Java 消息服务）的 API，方便集成各种 JMS 客户端。
- 支持多种消息格式，如 XML、JSON 和纯文本。
- 提供持久化、集群和高可用性的解决方案。
- 强大的管理界面和监控工具。
应用场景
- 分布式交易处理： 使用 Stomp 和 ActiveMQ 可以在分布式系统中实现实时、高效、可靠的消息传输。
- 实时应用集成： 通过 Stomp 客户端与 ActiveMQ 服务器建立连接，实现应用间的低延迟、高可用性的实时消息传输。
- 事件驱动架构： 使用 Stomp 和 ActiveMQ 可以实现事件驱动架构中的消息传递、解耦和负载均衡。
推荐的腾讯云相关产品
- 腾讯云 Stomp： 腾讯云 Stomp 是一个基于 Stomp 协议的消息代理服务，支持多种消息格式，提供客户端和服务器端的简单、高效的二进制编解码。
- 腾讯云 ActiveMQ： 腾讯云 ActiveMQ 是一个基于 Apache ActiveMQ 的消息代理服务，支持多种消息格式，提供持久化、集群和高可用性的解决方案。
产品介绍链接地址
相关·内容
1回答
傀儡版本: 3.1.1
尝试使用阿肯姆模块时：
package {'openjdk-6-jre-headless':
ensure => present,
}
class {'activemq':
version => '5.8.0',
user => 'activemq',
group => 'activemq',
home => '/opt',
console => true,
}
# follo
浏览 0提问于2013-05-15得票数 0
回答已采纳
下面是我的代码，它抛出了一个错误：
java.io.EOFException: at java.io.DataInputStream.readByte(Unknown Source)
Python或Java使用相同的凭据&主机/端口，它可以正常工作。
此代码失败：
public static void main(String args[]) throws Exception {
String host = "***********.mq.us-west-2.amazonaws.com";
Integer port = 61614; String user
浏览 0提问于2020-05-19得票数 1
EDIT2：我在这里的问题是由于对传输连接器如何在ActiveMQ中工作的了解不够。TL;DR是指ActiveMQ将在activemq.xml中定义的传输连接器配置之间隐式“转换”或“中继”消息。
编辑：附加信息，角应用程序接收到的STOMP消息用于调试和演示。因此，简单地将OpenWire消息转换为一个可读文本块就足够了。
我正在创建一个角度应用程序(最好是网站，避免本地应用程序)，其目标是通过ActiveMQ服务器上的web套接字“访问”并订阅OpenWire消息。如何让ActiveMQ将OpenWire消息转换为踩踏消息，并将这些消息发送到连接到ActiveMQ WebSocket连接器
浏览 0提问于2019-03-27得票数 1
回答已采纳
有一个ActiveMQ服务器运行在CentOS机器上。我可以使用OpenWire JMS与TCP和HTTP连接和使用消息。但是，当我尝试使用ActiveMQ测试STOMP客户端时，它会在connection.receieve上抛出此异常；
java.net.SocketTimeoutException: Read timed out
at java.net.SocketInputStream.socketRead0(Native Method)
at java.net.SocketInputStream.socketRead(SocketInputStream.java:116
浏览 4提问于2021-02-12得票数 0
回答已采纳
我正在使用一个用Node.js和Express编写的应用程序，并且我正在尝试使用连接到ActiveMQ服务器。
我可以使用Stomp让应用程序很好地连接到ActiveMQ，但我无法让系统在连接失败时自动重新连接。失败函数似乎只在最初连接成功，然后被切断时才会被调用，但如果在Node应用程序启动时ActiveMQ已经关闭，我确实会看到证明调用失败函数的错误消息。
var Stomp = require('stompjs');
var stompClient = Stomp.overTCP('localhost', 61612);
var stompStatus =
浏览 2提问于2014-03-13得票数 19
回答已采纳
下面是我从上搜索到的web客户端示例代码。
<script type="text/javascript">
var client = Stomp.client( "ws://localhost:61614/stomp", "v11.stomp" );
client.connect( "", "",
function() {
client.subscribe("jms.topic.test",
function( messag
浏览 8提问于2017-12-21得票数 0
我在连接Php客户端应用到支持Ssl的ActiveMq安装时遇到了问题。我看过很多资料，看得越多越觉得困惑。
到目前为止，我的设置使用了通过users/groups.properties和authorizationPlugin进行身份验证。这在常规连接上运行良好
对于Jks，我阅读了几篇文章，创建了ActiveMq存储和证书，并配置了以下内容
<sslContext>
<sslContext keyStore="file:${activemq.base}/conf/server.ks"
keyStorePassword
浏览 1提问于2018-10-07得票数 0
是否可以在客户端使用STOMP连接器，在服务器端使用ActiveMQ？以下是我的配置：
#client.cfg
connector = stomp
plugin.stomp.host = localhost
plugin.stomp.port = 6163
plugin.stomp.user = mcollective
plugin.stomp.password = password
#server.cfg
connector = activemq
plugin.activemq.pool.size = 1
plugin.activemq.pool.1.user = mcolle
浏览 0提问于2013-08-07得票数 1
2回答
我必须用python为ActiveMQ编写一个侦听器。
是否有任何可用于编写侦听器的python包。此外，Stomp/Openwire协议也是如此。启动activemq时，我看到三个带有协议的urls，即tcp、ssl、stomp。
如有任何帮助，将不胜感激。
编辑！：我遇到的另一个问题是，假设我们使用stomp和Open有线协议启动代理。假设代理Url现在是tcp://localhost:61616和stomp://localhost:61613。所以现在代理正在监听两个不同的端口。我的问题是，如果生产者在tcp端口上发布消息，该消息会被stomp端口上的订阅者使用吗？另外，如果tcp和st
浏览 2提问于2012-07-25得票数 3
回答已采纳
我正在做一些工作，将能源交易数据推送到ActiveMQ。我正在使用stomp.py库来捕获数据。下面的代码工作并提取数据标记为"BOALF“的所有数据。我需要使代码搜索多个标签(总共10个)。例如标签"BOD“和"SEL”。 我需要重写代码：headers={'selector': "JMSType='BOALF'"}，但我不确定如何包含几个标记，因为我所有的尝试都导致了错误。 import stomp
import time
class MyListener(stomp.ConnectionListener):
浏览 6提问于2019-02-25得票数 0
回答已采纳
我正在尝试使用ActiveMQ 5.8.0和PHP Stomp扩展来实现代理重新交付。但这并不像预期的那样工作。
回滚消息的PHP订阅者
define('QUEUE_NAME', '/queue/Task.Test');
$stomp = new Stomp();
$stomp->subscribe(QUEUE_NAME, array(
'activemq.prefetchSize' => 10,
));
while (true) {
$tid = uniqid('tid');
$sto
浏览 0提问于2013-07-08得票数 1
回答已采纳
我在机器A上有我的broker.yml，就像这样；
开发：
adapter: stomp
login: ""
passcode: ""
host: localhost
port: 61613
reliable: true
reconnectDelay: 5
foo:
adapter: stomp
login: ""
passcode: ""
host: --IP of machine B here--
port: 61613
reliable: true
reconnect
浏览 1提问于2010-08-19得票数 2
1回答
我们使用ActiveMQ，php和stomp。我们发现，当ActiveMQ重启时，使用stomp的用户无法识别丢失的连接。我发现，只有stomp 1.2支持心跳。而ActiveMQ使用的是stomp 1.1，最新的php stomp实现只支持1.0版本。我也尝试了amqp，但最新的实现，我发现ActiveMQ支持0.9.1，ActiveMQ使用1.0版本，当客户端连接amqp时返回错误：
WARN | Connection attempt from non AMQP v1.0 client. AMQP,0,0,9,1
WARN | Transport Connection to: tcp://
浏览 28提问于2015-12-11得票数 2
2回答
我目前正在使用stomp在activemq队列中发送和接收/消费消息，但是stomp使用者正在同步工作，这意味着stomp使用者一直在检查队列.But中是否有任何新消息，我需要做的是在新消息进入队列时让activemq通知我的stomp使用者。例如，就像Java中的Onmessage()方法一样。我找了好几天，但还是没有运气。我当前的php代码(如何使用stomp从队列中读取消息)：
while (true) {
$frame = $stomp->readFrame();
if ($frame != NULL) {
print "
浏览 1提问于2014-05-08得票数 2
回答已采纳
2回答
我正在使用Stomp消息，并且在我的客户端/浏览器代码中订阅了一个主题：
stompClient.subscribe('/topic/informer', function(greeting){
showGreeting(JSON.parse(greeting.body).content);
});
我使用的是一条向activemq主题发送消息的camel路由：
我都试过了：
<to uri="activemq:topic:informer"/>
和：
<to uri="stomp:topic:infor
浏览 2提问于2014-07-10得票数 1
2回答
我正在开发一个解决方案，它的架构是：
PHP -> JMS -> Camel -> several web services and endpoints.
根据：
..。我应该使用PHP STOMP客户端来使用JMS。这很好用。
我还使用了JMS client从ActiveMQ接收数据。
但是，我想使用Camel来路由JMS消息。我似乎无法让Camel与JMS / Stomp一起工作。
我看了一眼
..。但我不确定如何让它与Camel一起工作。
我还尝试了一个Spring camel-context.xml，其中的brokerURL指定了STOMP：
<bean
浏览 2提问于2013-02-24得票数 5
回答已采纳
最近，我开始在我的新项目中使用ActiveMQ作为消息中间件，这是我第一次尝试使用ActiveMQ，我之前参与过的项目使用了我们公司的内部消息框架，比如燕子。因此，在开始实现该系统之前，我需要明确一些设计要点。
在我们的系统中，使用ActiveMQ的案例包括发送邮件、向队列发送任务和从队列执行任务、异步请求/响应、，那么什么样的协议和网络连接才是我们的正确选择？I在这里列出了一些协议和网络连接选项：
ActiveMQ协议
MQTT
WS
Openwire
Stomp
Stomp
ActiveMQ网络连接
VM
TCP
UDP
HTTP
Failo
浏览 0提问于2015-09-14得票数 2
我已经使用tomee创建了一个项目，我希望使用stomp协议在我的web应用程序和使用ActiveMQ作为MOM的客户端之间交换消息，但是当我运行tomee时，会出现这样的异常：
线程“org.apache.activemq.transport.stomp.ProtocolConverter.(ProtocolConverter.java:116)传输服务器线程处理程序:stomp://0.0.0:61222”中的异常java.lang.NoClassDefFoundError: org.apache.activemq.transport.stomp.StompTransportFilter.
浏览 0提问于2014-03-14得票数 1
回答已采纳
2回答
我是一个新的ActiveMQ用户，试图用ActiveMQ启用Stomp。在此之前，我已经为CMS启用了打开线上的SSL，并且尝试使用CMS的证书设置和Stomp的新证书设置。
这里是我的证书设置
创建代理密钥存储库：
keytool -genkeypair -alias broker -keyalg RSA -keysize 4096 -sigalg SHA256withRSA -validity 4383 -keystore AMQBroker.ks -storepass "password" -keypass "password" -dname "C
浏览 3提问于2021-01-18得票数 0
1回答
我是新来的Stomp ActiveMQ。我想从安卓客户端创建一个登录名，我不知道如何使用ActiveMq。我已经安装了active mq，配置了stomp并运行了stomp。1.在activemq.xml中添加以下行时，从命令行运行activemq时出错：
<transportConnector name="stomp+nio" uri="stomp+nio://localhost:61612"/>
<transportConnector name="stomp+ssl" uri="stomp+
浏览 2提问于2012-06-06得票数 1
我有一个配置为stomp服务器的Apollo代理。现在，我想配置一个链接到Apollo代理的ActiveMQ代理，并启用双向消息传播。也就是说，我希望阿波罗代理和ActiveMQ代理同时作为消费者和生产者工作。
ActiveMQ broker上的此网络连接器配置是否符合我的要求？
<networkConnectors>
<networkConnector name="linkToApolloBroker"
uri="static:(stomp://apollo_broker_ip:61000)"
ne
浏览 2提问于2013-02-23得票数 0
1回答
我正在试用perl生成器来与ActiveMq对话。请找出我试过的密码。它给了我一个错误"* Net::STOMP::Client::IO::receive_data()：无法sysread()：EOF"**
调试后，错误在$stomp->connect();，请告诉我为什么这个错误在这里.我在网上找不到多少帮助。
提前感谢
我试着上网到我想要连接的网址。首先，它正在连接，最后是一些错误消息，如下所示：
CacheEnabledSizePrefixDisabled MaxInactivityDurationInitalDelay'TcpNoDelayEnabledM
浏览 0提问于2012-12-05得票数 0
目标是:使用Stomp连接到ActiveMQ故障转移集群(主/从)的PHP应用程序。
以下是这些版本：
ActiveMQ 5.7
PHP stomp 1.0.5稳定
PHP 5.4.4-14+cli 7u 14 (cli)
下面是设置：
2台服务器采用ActiveMQ；
安装在两台服务器上，共享一个VIP
PHP脚本如下
<？php $queue = '/queue/test'；尝试{ $stomp = new (“tcp://VIP:61613”)；}$stomp(StompException $e) {$stomp(‘连接失败
浏览 2提问于2014-10-03得票数 1
我现在可以使用xbean启动ActiveMQ，但是ActiveMQ没有在引导时作为UNIX服务启动
/home/username/activemq/bin/activemq start xbean:/home/username/activemq/conf/my-activemq.xml
控制台提示我运行安装程序，所以我
/home/username/activemq/bin/activemq setup etc/default/activemq
我搞不懂为什么控制台说如果我使用xbean就要创建一个配置文件
然后我创建了producer.php和consumer.php
cd /etc/ini
浏览 1提问于2012-08-26得票数 1
我正在尝试用ActiveMQ替换一些定制的消息队列，并且我需要在Perl中与它们交谈(大量)。ActiveMQ提供了Stomp接口，而Perl提供了Net::Stomp，所以这看起来应该很好，但事实并非如此。
即使我通过Stomp发送BEGIN命令，使用send发送的消息也会立即发布，如果我中止事务，什么也不会发生。
我找不到任何明确的答案，表明这是不可能的，这是可能的，或者有相关的配置。此外，Stomp似乎不是一个检查来自服务器的错误响应的好协议。
我是不是不走运？
浏览 2提问于2008-09-17得票数 10
1回答
我每两个月左右就会遇到一个问题。我的activemq服务器死了，日志中满是SocketExceptions。
我有一个使用stomp向ActiveMQ发送消息的PHP应用程序和一个使用这些消息的Java应用程序。
我在另一台服务器上使用了activemq，它在发送/消费消息时只使用java应用程序，而且从未像这样失败过。我觉得Stomp有什么问题。
stomp代码是非常基本的，不发送任何奇怪的东西。只有设置了消息属性的消息。每次发送邮件后，stomp代码都会关闭连接。
我已经看过了，没有什么不正常的地方。
不过，netstat确实有很多：
tcp6 61616 127.0.0.1:61616
浏览 0提问于2011-04-28得票数 2
回答已采纳
我正在尝试使用stomp协议使用c#从activeMQ的队列中接收/发送消息。因为我对activemq和stomp了解不多。所以我正在寻找一些合适的文档或示例代码，通过它们我可以一步一步地学习。
static void Main(string[] args)
{
Apache.NMS.Stomp.ConnectionFactory factory = new Apache.NMS.Stomp.ConnectionFactory(new Uri("stomp:tcp://localhost:61613"));
IConnection
浏览 3提问于2013-01-22得票数 0
回答已采纳
我正在编写一个简单的Java客户端给AmazonMQ，它通过ssh运行ActiveMQ和stomp协议(因此他传输的是stomp+ssl
// java
import java.util.Enumeration;
// jms
import javax.jms.IllegalStateException;
import javax.jms.JMSException;
import javax.jms.Queue;
import javax.jms.QueueBrowser;
import javax.jms.QueueSession;
import javax.jms.Session;
im
浏览 7提问于2022-02-09得票数 0
回答已采纳
1回答
我正在尝试创建一个json，我希望将它从一个生产者发送到另一个生产者，后者稍后需要分解它并使用它。所以我使用了activemq和stomp，因为我是用php编程的。我为我的制作人准备了以下程序：
<?php
namespace Stomp;
require __DIR__ . '/../vendor/autoload.php';
use Stomp\Client;
use Stomp\StatefulStomp;
use Stomp\Network\Connection;
use Stomp\Transport\Message;
hea
浏览 0提问于2017-08-16得票数 1
我正试图在傀儡主人(开源木偶)上设置source /activemq。我遇到了一个ActiveMQ不承认Stomp协议的问题。下面是我的/etc/activemq/instances-enabled/activemq/activemq.xml文件中应该启用stomp+ssl的相关片段：
<transportConnectors>
<transportConnector name="openwire" uri="tcp://0.0.0.0:61616"/>
<transportConne
浏览 6提问于2016-10-03得票数 3
嗨，我正在使用stomp.py模块发送和接收来自
使用python的ActiveMQ。
在接收消息时，侦听器将在指定的睡眠时间内读取多条消息。
但我只需要读一条信息。这在java中是可能的。如何使用STOMP从ActiveMQ读取单个消息？
下面是我正在测试的侦听器脚本，
import stomp
import time
class SampleListener(object):
def on_message(self, headers, msg):
print(msg)
conn = stomp.Connection([('localhost
浏览 3提问于2017-05-11得票数 0
是否可以通过Stomp订阅到ActiveMQ代理并访问JobScheduler (随后通过jobId删除预定消息)？
我有一组由两个web服务器产生的队列"PROD“的预定消息，当同一个web服务器上发生事件时(注意到jobIds)，希望将它们从JobScheduler中删除，以便使用者(用Java编写并位于多个远程服务器上)不接收它们。
我使用ActiveMQ broker v5.9.1和Stomp连接到broker表单PHP。
浏览 8提问于2015-08-30得票数 1
回答已采纳
1回答
确认stomp消息时出错
、、、
我们在websockets上使用spring，它得到ActiveMQ 5.11.1的支持。当客户端ACK收到消息时，我会得到以下异常：
"<<< ERROR
内容类型:文本/纯文本消息:意外接收到的消息-ID\cjanus-61128-1430365808166-2\c1\c1\c1内容-长度:722
org.apache.activemq.transport.stomp.ProtocolException:意外接收到的消息-ID ID:janus-61128-1430365808166-2:1:-1:1:1 :1:1:1:1:1在org.apache.activem
浏览 1提问于2015-04-30得票数 1
回答已采纳
我们正在运行JBoss 7.4.0。我们已经运行了嵌入式Artemis，并且通过运行在JBoss和外部Java客户机中的应用程序成功地使用它，没有任何问题。
我们有一个新的要求，允许另一个组将消息放到队列中。他们使用Python，它使用STOMP协议。我无法在JBoss嵌入式Artemis中工作。它在Artemis独立经纪人中运行得很好。
对于JBoss配置和设置，我添加了一个新的套接字绑定和远程受体，如下所示：
<socket-binding name="external-messaging-stomp" port="61613"/>
...
浏览 11提问于2022-08-19得票数 0
回答已采纳
如何使用Go中的故障转移stomp连接URI连接到ActiveMQ？使用客户端，我尝试了下面的代码，但它无法连接。
if conn, err = stomp.Dial("tcp", "failover:(tcp://10.01.02.03:61613,tcp://10.04.05.06:61613)?startupMaxReconnectAttempts=2"); err != nil {
panic(fmt.Sprintf("Could not connect to ActiveMQ using brokerUri %v. Can no
浏览 5提问于2016-03-09得票数 0
回答已采纳
2回答
这是我的蓝图代码。
内部activemq:queue:x消息可以工作。
外部stomp:queue:y消息不会。
<bean id="artemisConnectionFactory"
class="org.apache.activemq.artemis.jms.client.ActiveMQJMSConnectionFactory">
<argument value="${activeMq.Uri}" />
<argument value="${activeMq.userName}&
浏览 2提问于2018-11-29得票数 0
回答已采纳
我试图使用Spring连接到本地计算机上运行的ActiveMQ代理，如下所示
在链接中，使用内存代理，但我更喜欢使用代理服务器，在我的例子中，它使用的是ActiveMQ。
我通过类路径中的文件application.properties中的以下配置将activemq指定为Spring
spring.activemq.broker-url=stomp://localhost:61611
spring.activemq.password=password
spring.activemq.user=admin
下面是我的pom.xml中的依赖项
<parent>
<grou
浏览 4提问于2017-05-07得票数 1
我正在使用Net:Stomp修改一些现有的代码，从能够处理单个主题到能够处理多个主题。有人能告诉我这种方法是否可行吗？它现在不起作用了，因为在它期望事务收据的地方，它得到了关于另一个主题的第一条消息。我想知道，在我试着修复它之前，我是否只是把它弄错了。
工作流程如下所示：
# first subscribe to three different queues
for $job (qw/ JOB1 JOB2 JOB3 /){
$stomp->subscribe({
"ack" => "client",
"destination
浏览 2提问于2011-09-26得票数 1
1回答
我们使用ActiveMQ 5.16.1与客户端一起使用以下代码片段在NodeJS应用程序中创建持久订阅：
var connectOptions = {
"host": "",
"port": amqPort,
rejectUnauthorized: false,
checkServerIdentity: () => { },
"connectHeaders": {
"heart-beat": "15000,15000",// hear
浏览 2提问于2021-05-11得票数 1
回答已采纳
我有两台流浪机。第一个叫做"web“，包含一个小的Ruby应用程序，第二个叫做"mq”，安装了ActiveMQ。我无法将我的应用程序连接到ActiveMQ。
流浪配置文件：
config.vm.define :web do |web_config|
web_config.vm.network("33.33.33.10")
web_config.vm.box = "lucid32"
config.ssh.forwarded_port_key = "ssh"
config.vm.forward_port
浏览 0提问于2011-12-31得票数 3
回答已采纳
在使用ActiveMQ队列中的数据时，im遇到了以下问题
使用以下代码：
$stomp = new Stomp($activeMQURI);
$stomp->subscribe($queue);
while ($stomp->hasFrame()) {
$frame = $stomp->readFrame();
if ($frame) {
$stomp->ack($frame);
}
}
在$stomp->hasFrame()返回false之前，它只会遍历大约1-10条消息。问题是队列中还有10k条消息！
当我在确认之
浏览 3提问于2012-12-21得票数 1
我正在为Ada开发一个STOMP绑定，它使用TCP/IP作为客户机和配置为STOMP代理的ActiveMQ服务器之间的传输，工作得很好。我也想支持UDP (例如，脚踏UDP)，然而，在ActiveMQ文档或网络搜索中缺乏相关信息表明这是不可能的，甚至可能没有任何意义:-)
以这样或那样的方式进行确认(如果可能的话，还要提供ActiveMQ配置摘录)将不胜感激。
浏览 0提问于2010-04-22得票数 1
回答已采纳
我使用的是ActiveMQ和PHP。$stomp->readFrame()函数运行缓慢，如何修复？我尝试过其他语言，如Java、Nodejs等。但它们在相同的连接属性中工作是完美的。我在php中遇到了一个问题。
try {
$url = 'tcp://'.$host.":".$port;
$stomp = new Stomp($url, $user, $password);
$stomp->subscribe($destination);
$start = now();
$count = 0;
echo "Waiti
浏览 8提问于2018-07-18得票数 0
我收到了一个用Spring实现的Web应用程序，它使用WebSockets消息传递的STOMP实现，类似于描述的 (后端是RabbitMQ )。它在Tomcat上运行，我可以使用常规URL(例如http://host/server/)连接到应用程序。我还得到了一个演示客户端-一个JSPX页面，它使用了现代化的WebSockets和SockJS。演示客户端中的连接代码如下所示：
if (Modernizr.websockets) {
socket = new WebSocket('ws://host/server/endpointx');
}
else {
soc
浏览 3提问于2016-08-08得票数 19
回答已采纳
我有一个用于STOMP 1.2连接的侦听器(继承自stomp.ConnectionListener)。它目前订阅了3个队列。以下是连接和订阅代码。 当ActiveMQ 5.16.2服务器关闭时，监听程序的on_disconnected函数似乎被多次触发，即使在这两次之间没有进行重新连接尝试。 你知道为什么会这样吗？这与订阅的数量有什么关系吗？ 更新:根据要求添加一个最小的可重现示例。此处不能包括主机、端口或任何凭据。 server.py import stomp
from time import sleep
if __name__ == '__main__':
co
浏览 146提问于2021-07-20得票数 0
我尝试使用ApachePythonArtemis2.24发送和接收消息，使用ActiveMQ使用STOMP发送消息，并使用接收消息。Stomp.py版本为8.0.1。Python版本为3.10.4。Java版本是1.8.0_342。
如果我运行基于Java的消息使用者并使用Java代码发送消息，那么一切都正常。但是，如果我使用Stomp.py向队列发送消息，则在接收端得到以下异常：
Exception in thread "main" java.lang.IndexOutOfBoundsException: Error reading in simpleString, leng
浏览 10提问于2022-09-18得票数 0
回答已采纳
我正在尝试连接到位于here的达尔文推送端口馈送。当我尝试按照wiki的说明进行连接时，我得到了2个错误中的1个。 如果我省略了订阅选项，我会得到一个身份验证错误，如果我包括了它们，它会告诉我不能创建对队列的持久订阅。 如果有人能告诉我哪个错误更接近于连接，那将是一个很大的帮助。 package main
import (
"fmt"
"github.com/Showmax/go-fqdn"
"github.com/go-stomp/stomp"
"github.com/go-stomp/stomp/
浏览 39提问于2020-09-05得票数 0
回答已采纳
1回答
我有支持性的ActiveMQ
<transportConnectors>
<transportConnector name="stomp" uri="stomp://0.0.0.0:61616?maximumConnections=1000&wireFormat.maxFrameSize=104857600"/>
</transportConnectors>
客户端连接到ActiveMQ，并可以将消息发送到：
#!/usr/bin/python2
# -*- coding: utf-8 -*-
from
浏览 2提问于2016-12-07得票数 0
回答已采纳
遵循activemq.apache.org的指导方针，使用openwire作为传输协议来启动和运行是相当容易的。
让URI具有trace选项，就可以看到握手和所有操作：@testing.activeMqInstance=failover:tcp://localhost:61616?trace=true
09:36:06.764 [ActiveMQ Task-1] DEBUG o.a.a.t.failover.FailoverTransport - Attempting 0th connect to: tcp://localhost:61616?trace=true
09:36:06.780
浏览 4提问于2013-02-13得票数 0
回答已采纳
当我使用ActiveMQ向发送消息时，消息以BytesMessage的形式发送。不过，我想发送一个TextMessage。
根据，这可以通过不发送内容长度头来实现：
..。然而，该协议确实支持内容长度标头。为了在Stomp和JMS之间提供更健壮的交互，ActiveMQ键从包含这个头来确定在从Stomp发送到JMS时要创建什么样的消息类型。逻辑很简单：
包含内容长度的标题=>结果消息
是的，=> BytesMessage
无=> TextMessage
在从JMS到Stomp的过程中，也可以遵循同样的逻辑。可以编写Stomp客户端以取消包含内容长度标题的内容，以确定要向用户提
浏览 7提问于2015-07-22得票数 4
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
实时音视频
对象存储
云直播活动推荐
腾讯云开发者
