rabbitmq相关内容

大众运输临时队列

我正在开发使用masstransit和Rabbitmq的客户端应用程序.在应用程序启动时，我正在创建具有唯一名称的新队列，以便通过masstransit(请求/响应模型)与服务器应用程序进行通信.在关闭应用程序时，我应该删除此队列，但是如果客户端应用程序崩溃，则Rabbitmq上将出现队列. 是否可以通过masstransit创建临时队列，当客户端与队列断开连接时，Rabbitmq会自动删除 ..
发布时间：2020-05-06 09:12:00 C#/.NET

在MassTransit上禁用循环消息消费

我已经创建了一个基本的演示pub/sub应用程序，该应用程序可通过MassTransit在localhost上运行. 我想要实现的是发布一条消息，所有订阅者都应该收到该消息. 此刻，在我的环境中，我启动了一个发布者应用程序和两个订阅者应用程序.但是当我发布消息时，订阅者会依次收到消息. 我的发布/订阅代码: 发布: var bus = Bus.Factory.Crea ..
发布时间：2020-05-06 09:11:58 C#/.NET

使用RabbitMQ进行MassTransit:何时将消息移至错误队列

我正在使用RabbitMQ版本3.0.2&我在错误队列中看到接近1000条消息.我想知道 什么时候消息被移到错误队列? 是否有办法知道为什么某条消息被移至错误队列? 有什么方法可以将消息从错误队列移到普通队列? 谢谢 解决方案 a)他们未能反序列化，或b)消费者抛出了对该消息五次处理的异常 不是真的...如果您查看队列中的消息，则有效载荷标题可能包含注释，但我认为我们没有 ..
发布时间：2020-05-06 09:11:51 其他开发

MassTransit封顶消息速率为10

我设置了与RabbitMQ一起使用的大众运输消费者服务，但我不知道如何提高消费者的速度-似乎硬性限制每秒接收10条消息. 我尝试了此处列出的步骤: https://groups.google.com/forum/#！可以提高邮件的下载速度. 我的配置如下: ServiceBusFactory.ConfigureDefaultSettings(x => { ..
发布时间：2020-05-06 09:11:46 其他开发

获取MassTransit消息重试量

我正在使用Masstransit + RabbitMQ.我的使用者之一实施重试策略，我想知道一旦消息进入错误队列，是否有任何方法可以使消息重试? 我还想知道MT计数重试的方式，因为我不希望使用RabbitMq服务器在邮件标题中找到任何相关信息. 谢谢. 解决方案 您可以在消费者中使用以下方法重试重试次数. consumeContext.GetRetryAttempt() ..
发布时间：2020-05-06 09:11:22 C#/.NET

MassTransit在RabbitMQ中添加了什么?

在 MassTransit 之上进行构建与直接在RabbitMQ ? 我相信MassTransit提供的一个好处是“类型"交换(按接口/类型发布订阅)，因此与普通的RabbitMQ交换相比，消息的内容是非结构化的文本/blob，因此消息的内容是结构化的. /p> MassTransit还提供哪些其他好处? 解决方案 MT在仅使用RabbitMQ的基础上添加的内容: 多线程并发 ..
发布时间：2020-05-06 09:11:07 其他开发

为什么在消息排队系统(例如MSMQ/RabbitMQ等)之上需要NService Bus/MassTransit之类的服务总线框架?

在分布式消息事务世界中，我试图了解开发分布式系统所涉及的不同部分.据我了解，您可以使用带有消息队列系统支持的企业总线来设计消息传递系统.为什么同时使用两者是一个好主意?通过仅对消息排队系统进行编程是否可以实现相同的目的?两者一起使用有什么好处? 解决方案 您当然可以直接针对消息传递基础结构进行编码，并且会发现优缺点.每次运输.但是，在此过程中您需要做出许多决定，而这正是服务总线可以提供帮助 ..
发布时间：2020-05-06 09:11:05 其他开发

Masstransit队列以总线为前缀，并以随机字符串作为后缀

我正在接管一个项目，该项目将Masstransit用作RabbitMQ的抽象. 我看到很多队列以"bus"为前缀，并以一些随机字符串作为后缀. 这些队列用于什么以及如何创建?任何提示都将受到欢迎. 解决方案 那是临时队列. 文档中的更多信息 此类 MassTransit的a>生成它(请参见CreateTemporaryQueueName方法调用) ..
发布时间：2020-05-06 09:11:01 C#/.NET

如何使用Logstash&设置内容类型rabbitmq输出?

我想用logstash解析日志，并通过rabbitmq发送结果.使用这些结果的应用程序正在等待content_type设置为"application/json"的消息.目前，我的消息没有任何属性，我的应用程序无法处理该消息. 您能告诉我logstash如何将属性"content_type"设置为"application/json"的消息发送到rabbitmq吗? 预先感谢&最好的问候， ..
发布时间：2020-05-04 03:37:09 其他开发

rabbitMQ访客登录失败

我已经在Windows中设置了RabbitMQ及其管理plubin， 我在 的路径中找到了"EXAMPLE FILE"类型的rabbitmq.config文件. "... AppData \ Roaming \ RabbitMQ"和"C:\ Program Files(x86)\ RabbitMQ Server \ rabbitmq_server-3.3.1 \ etc" 我将{l ..
发布时间：2020-05-03 09:18:36 其他开发

重试兔子消息时记录消息

我们在应用程序中使用RabbitMQ将付款请求排队，并让另一个队列将结果发送回调用方.在这两种情况下，客户端都请求了将重试的重试策略，但是该策略将永久重试，但是会在每次重试中在日志中放置一些内容，例如“第x次重试事务..."，以便外部系统可以通过监视来检测备份的内容日志文件. 我正在这样创建侦听器容器: public SimpleMessageListenerContainer pay ..
发布时间：2020-05-03 08:40:14 其他开发

如何记录所有Rabbit MQ消息?

我们正在使用RabbitMQ服务器在应用程序之间进行消息传递.我们需要为进入Rabbit服务器的所有amqp消息创建一个中央日志.我们的目的不是临时调试，而是可审核性.理想情况下，我可以先登录到指定文件，然后再登录到Logly或Splunk等外部系统. 我已经探索过打开Firehose并使用跟踪插件，但是所讨论的队列并不持久.我也不确定如果在日志尚未开始后将新队列和交换添加到虚拟主机，这些解 ..
发布时间：2020-05-03 08:07:26 其他开发

在RabbitMQ侦听器中隐藏运行时异常

在某些情况下，我使用了一些例外来拒绝该消息，但是在控制台中却显示了例外，乍一看似乎还不行. 如何从登录控制台/文件中隐藏该特定异常 我正在使用spring-boot和默认记录器！ public static class UndispatchException extends AmqpRejectAndDontRequeueException{ publi ..
发布时间：2020-05-03 07:22:14 Java开发

Log4J 2版本不适用于RabbitMQ&春季靴

我在RabbitMQ Project中的pom.xml下面.也附有示例代码.有人可以帮助我解决我面临的错误吗?我尝试过在网上实施各种解决方案，但没有成功.我也尝试过使用Log4J xml. 我在许多站点上阅读到，如果我使用的是log4j，那么我还必须排除一些依赖关系.在我的pom xml中，我已将它们排除在外.但是仍然没有成功. ..
发布时间：2020-05-03 06:58:05 其他开发

风暴拓扑未提交

我已经配置了我的机器zookeeper，nimbus，supervisor正常运行，并且我的拓扑在LocalCluster中工作 LocalCluster cluster = new LocalCluster(); cluster.submitTopology("SendPost", conf, builder.createTopology()); Utils.sleep(100000000 ..
发布时间：2020-05-03 06:38:38 Java开发

负载均衡器在RabbitMQ中的工作方式

我是RabbitMQ的新手，请为我一些琐碎的问题原谅: 1)如果在RabbitMQ中进行集群，则如果一个节点发生故障，则将负载转移到另一个节点(而不停止其他节点).同样，我们也可以在不停止集群中现有节点的情况下将新节点添加到现有集群中.正确吗? 2)假设我们从单个RabbitMQ节点开始，并在其上创建100个队列.现在，生产者开始以更快的速度发送消息.为了处理此负载，我们添加了更多节点 ..
发布时间：2020-05-03 03:17:26 其他开发

如何使RabbitMQ可扩展?

我尝试测试RabbitMQ，但发现Rabbitmq存在一些问题: 如果我创建了一个由3个节点组成的集群，则发布/交付的速度不能超过6000/s. 另一方面，如果我使用单个节点，则可以发布/传送直到25000/s. 这意味着，我添加更多的节点，更多的性能将会下降. 但来自本文: https://blog.pivotal.io/pivotal/products/rabbitmq-hits-one ..
发布时间：2020-05-03 03:16:59 其他开发