amqp相关内容

在Go amqp客户端中设置连接友好名称

我在我的应用程序中使用 http://github.com/streadway/amqp 包为了处理到远程RabbitMQ服务器的连接.一切正常，一切正常，但我有一个问题. 连接的当前名称是"ip:端口"，因此当来自同一IP +端口的多个连接时，它们几乎不可区分.如果您可以为每个连接指定一个名称，那就太好了. 有什么办法为每个连接设置不同的友好名称吗? 解决方案 RabbitM ..
发布时间：2020-08-24 02:08:45 其他开发

Spring AMQP异常处理基础知识

我有一个Listener类(实现了Spring的MessageListener接口)，在该类中，如果发生异常，我不需要重新排队任何消息，但是我想将消息发布到另一个队列中. 似乎我需要监听器来捕获AmqpRejectAndDontRequeueException，但是我已经读到我需要它来引发异常.如果这样做，则无法重新发布该消息. 我应该只捕获一个普通的异常，然后在该处重新发布吗?在那个 ..
发布时间：2020-08-24 02:07:32 其他开发

仅使用React \ stomp消费来自RabbitMQ的N条消息，分别对其进行确认，然后退出

我正在将RabbitMQ与PHP react \ stomp一起使用.我有两个队列-一个是“待办事项"，另一个是“完成".消费者从“待办事项"中读取内容，进行工作，确认消息，然后将其发布到“完成"队列中. 有什么方法可以确保我只消耗“待办事项"中的N条消息(并分别确认它们)然后退出?造成这种情况的主要原因是我们不想拥有长时间运行的使用者，而我们希望在N条消息后重新启动它们. 解决方案 ..
发布时间：2020-08-24 02:07:28 其他开发

如何使用Java RabbitMQ并设置URI服务器?

我正在使用RabbitMQ Java API连接到RabbitMQ服务器.我想使用ConnectionFactory.setUri(...)配置要使用的服务器.它似乎在破坏虚拟主机. 有一个名为/的默认虚拟主机. import com.rabbitmq.client.ConnectionFactory; import com.rabbitmq.client.Connection; im ..
发布时间：2020-08-24 02:07:25 Java开发

如何使用Node.js在RabbitMQ中实现远程过程调用(RPC)

所以我想使用一个Json并将其解析为Object，然后实现RPC RabbitMQ Server，以便我可以通过RabbitMQ将对象发送到Server，然后该Object将继续保存在本地Array和可以通过RPC从该服务器返回到客户端的通用唯一ID，该ID会告诉您该对象的确切存储位置. 官方网站显示了RabbitMQ中RPC的一些实现，您可以在此处找到其实现 //this is my se ..
发布时间：2020-08-24 02:07:23 其他开发

Azure IoT中心基本接收示例，AMQP错误

我正在使用此处提供的教程来研究Azure的Iot集线器和连接的技术，以供参考:运行接收器示例时(本文的此部分:我在网上遇到错误: var d2cPartitions = eventHubClient.GetRuntimeInformation().PartitionIds; 我收到此错误(底部有完整的错误日志): Message=An AMQP error occurred (co ..
发布时间：2020-08-24 02:06:20 其他开发

NodeJS AMQP客户端无法连接

最近两天我发疯了，我无法通过持久交换和持久队列在NodeJS客户端上建立连接. 因此，PHP代码创建并发送消息: 'localhost', 'vhost' => 'bvh', 'port' => 5672, 'login' => 'bizneus', 'password' ..
发布时间：2020-08-24 02:06:16 PHP

使用RabbitMQ的选择性路由

我有一些队列绑​​定到一个主题交换，例如带有路由键: 1) big.yellow.rabbit 2) small.*.dog 3) small.*.* 4) *.*.cat 5) *.*.* 我希望RabbitMQ通过以下逻辑选择一个队列来放置我的消息: 重合标记的数量应尽可能大 第一个标签的重合度比第二个标签的重合度... 上述键的示例: big.yellow.ra ..
发布时间：2020-08-24 02:06:12 其他开发

有没有人成功地将芹菜和塔一起使用

我有一个基于塔的Web应用程序，我很想在一段时间内使用芹菜+ Rabbitmq.我看过celery-pylons项目，但没有成功使用它. 我对celery的主要问题是:我在哪里放置celeryconfig.py文件，或者是否有其他方法可以指定celery选项，例如.从pylons应用程序中获取BROKER_HOST之类的东西(使用django-celery时，也可以将选项放入django s ..
发布时间：2020-08-24 02:06:05 其他开发

在哪里可以找到php-amqp文档?

我们计划从PHP使用RabbitMQ，我们决定使用php-amqp，因为它支持PHP 5.2.唯一的问题是我找不到该PECL库的适当文档 测试. 非常抱歉，我们还没有编写适当的文档和示例. 如果您对 php-amqp 扩展名还有其他疑问，可以随时在此处发布更多问题或亲自与我联系. ..
发布时间：2020-08-24 02:06:01 PHP

RabbitTemplate接收消息并重新排队

我的问题与这一问题非常相似: RabbitTemplate接收并重新排队 不幸的是，尽管答案不符合我的需要，但已被标记为已回答. 我想模仿Rabbit Admin UI的功能，即我想从队列中同步读取消息，但又不想让队列丢失它们，即像偷看一样. 此处的答案 RabbitTemplate接收和重新排队建议使用侦听器，但在这种情况下，会无限期地阅读和排队.我只想获取并重新排列消息一次，所以我 ..
发布时间：2020-08-24 02:05:57 其他开发

如何在spring-amqp中设置消费者标签值

我正在尝试将消费者标签更新为比随机生成的字符串更具信息性的标签.我们使用的模式包括主机名+标识符+随机字符串.在我们的其他服务(即带有ampqlib的NodeJS)中，这可以很好地工作，因为它们提供了一种传递此值的机制. 但是，对于我们的Java服务，我们使用spring-amqp，似乎无法传递消费者标签值.我看了BlockingQueueConsumer，目前它已硬编码为一个空字符串: ..
发布时间：2020-08-24 02:05:54 Java开发

使用RabbitMQ获取长期运行任务的结果

我有一个场景，客户端发送一个http请求来下载文件.该文件需要动态生成，通常需要5到15秒.因此，我正在研究将此操作分为3个http请求的解决方案. 第一个请求触发文件的生成. 客户端每5秒轮询一次服务器，以检查文件是否准备好下载 对轮询请求的响应为肯定时，客户端开始下载文件 要实现这一点，我正在研究像RabbitMQ这样的Message Queue解决方案.它们似乎提供了一个可靠 ..
发布时间：2020-08-24 02:03:44 其他开发

我应该为基于浏览器的实时游戏选择AMQP或XMPP哪一个?

我正在为基于浏览器的无Flash JavaScript实时回合制游戏选择AMQP(RabbitMQ)与XMPP(eJabberd)之间.我对AMQP和XMPP协议了解不多.我想使用PHP进行用户授权，并使用MySQL进行一些数据存储检索.据我了解，RabbitMQ有PHP客户端，而eJabberd没有. 我了解的是javascript客户端调用PHP脚本并操纵必要的处理，然后传递给AMQP或 ..
发布时间：2020-08-24 02:03:42 PHP

RabbitMQ管道破裂错误或消息丢失

使用pika库的BlockingConnection连接到RabbitMQ，发布消息时偶尔会出现错误: 致命套接字错误:error(32，'Broken pipe') 这来自一个非常简单的子过程，该子过程将一些信息从内存队列中取出，并将一条小的JSON消息发送到AMQP中.仅当系统在几分钟内未发送任何消息时，才会出现该错误. 设置: connection = pika.Bl ..
发布时间：2020-08-24 02:03:37 Python