rabbitmq 第50页 - IT屋-程序员软件开发技术分享社区

并发处理Rabbitmq消息

我在此处询问了为什么开始使用Thread.Run的进程未执行预期的并发请求. 此问题背后的原因是我试图创建一个类，该类可以将消息从Rabbitmq队列中拉出并并发地处理它们，直到并发消息的最大数量为止. 为此，我在EventingBasicConsumer类的Received处理程序中得到了以下内容. async void Handle(EventArgs e) { a ..

发布时间：2020-05-14 01:46:32 c# multithreading rabbitmq C#/.NET

Rabbitmq队列填满了芹菜任务

我正在使用Celery通过其IP地址调用多个硬件单元.每个单位将返回值列表.下面的应用代码 # create a list of tasks modbus_calls = [] for site in sites: call = call_plc.apply_async((site.name, site.address), expires=120) # expires after ..

发布时间：2020-05-14 01:17:23 python multithreading rabbitmq celery mnesia Python

我们有一个项目正在使用Spring-AMQP来消耗来自RabbitMQ代理的消息.我们希望增加使用方的并发性，以便多个工作线程可以并行处理消息.我首先阅读了本机RabbitMQ客户端的文档，这使我想到了使用单个使用者的设计，并且预取计数> 1以控制并行性.直接使用RabbitMQ客户端，这似乎很自然. DefaultConsumer的handleDelivery方法可以产生一个新的Runnable ..

发布时间：2020-05-13 23:32:34 spring multithreading rabbitmq spring-amqp 其他开发

消耗具有多个线程的Rabbitmq消息队列(Python Kombu)

我有一个带有单个队列的RabbitMQ交换.我希望创建一个运行多个线程并尽可能快地通过此队列的守护程序. “工作"涉及与外部服务的通信，因此每个消费者内部都会发生大量的阻塞.因此，我想拥有多个线程来处理来自同一队列的消息. 我可以通过消耗主线程上的队列，然后将传入的工作分配到其他线程池中来实现此目的，但是有没有办法启动多个使用方，每个使用方都在自己的线程上下文中? 解决方案看 ..

发布时间：2020-05-13 23:14:18 python multithreading rabbitmq kombu Python

C#RabbitMQ客户端线程安全

ConnectionFactory factory = new ConnectionFactory {HostName = "localhost"}; using (IConnection connection = factory.CreateConnection()) using (IModel channel = connection.CreateModel()) { channel ..

发布时间：2020-05-13 23:10:21 c# multithreading thread-safety rabbitmq C#/.NET

在多租户系统中，如何在RabbitMQ中将队列设置为私有/安全?

我已经阅读了RabbitMQ提供的入门指南，甚至将第六个示例贡献给了 stormed-amqp ，所以我对知识有所了解关于AMQP. 但是，该指南并不全面，避免了身份验证和授权之类的问题. 我们正在设计一个多租户系统，该系统将在RPC类型的情况下使用RabbitMQ. RPC实现的不同之处可能在于，远程过程实际上将是系统上的其他租户程序. 基本上，我想隔离数据总线，其中包括以下断 ..

发布时间：2020-05-13 20:25:02 security rabbitmq amqp multi-tenant 其他开发

芹菜:如何限制队列中的任务数量并在满时停止进食?

我是Celery的新手，这是我的问题: 假设我有一个脚本，该脚本经常应该从数据库中获取新数据并使用Celery发送给工作人员. tasks.py # Celery Task from celery import Celery app = Celery('tasks', broker='amqp://guest@localhost//') @app.task def proce ..

发布时间：2020-05-13 19:32:21 python multithreading rabbitmq multiprocessing celery Python

从m子将消息存储在rabbitmq中

下面是我的流程，我正在尝试将salesforce批次信息存储到Rabbit MQ中的队列中 ..

发布时间：2020-05-13 02:05:24 rabbitmq mule mule-studio 其他开发

Paho Rabitmqq连接失败

这是我的paho客户代码 // Create a client instance client = new Paho.MQTT.Client('127.0.0.1', 1883, "clientId"); // set callback handlers client.onConnectionLost = onConnectionLost; client.onMessageArrived ..

发布时间：2020-05-12 20:19:23 rabbitmq mqtt paho 其他开发

在Rabbit MQ中禁用保留的MQTT消息

出于遗留原因，我需要在运行RabbitMQ的MQTT节点上禁用保留的消息. 在研究了该问题之后，似乎Rabbit MQ团队确实添加了这样一个功能在名为 rabbit_mqtt_retained_msg_store_noop.erl . 否则，我对代码库不熟悉，并且在文档的任何地方都找不到提及noop固定器的信息. 如何启用rabbit_mqtt_retained_msg_stor ..

发布时间：2020-05-12 20:19:00 rabbitmq mqtt 其他开发

如何使用MQTT Paho订阅RabbitMQ队列

我正在尝试从我的Android应用连接到一个称为“消息"的队列. 生产者(一种基于AMQP协议的Web服务)已经连接，可以通过RabbitMQ管理面板进行检查. 要从我的Android设备进行连接，我正在这样编码. private void connect() throws Exception { this.sampleClient = new MqttClient(t ..

发布时间：2020-05-12 20:15:37 rabbitmq mqtt 其他开发

将mqtt协议与kafka用作消息代理

我们如何将mqtt协议与kafka用作消息代理? 客户端(android/ios/桌面Java应用程序等)将使用mqtt phao客户端库生成和使用消息，该库可以使用kafka作为消息代理以不同的语言提供. 有什么建议吗? 解决方案您可以使用Kafka源连接器，该连接器将从MQTT代理(如Mosquitto)将数据流式传输到Kafka集群中.参见 https://github ..

发布时间：2020-05-12 20:15:27 architecture rabbitmq scalability apache-kafka mqtt 其他开发

发送许多发布消息:进行中的发布过多错误

这是paho异步客户端: client = new MqttAsyncClient(appProps.getProperty("mqtt.broker"), appProps.getProperty("mqtt.clientId"), new MemoryPersistence()); client.setCallback(this); cli ..

发布时间：2020-05-12 20:14:32 rabbitmq mqtt paho 其他开发

使用pika的python中的SparkStreaming，RabbitMQ和MQTT

为了使事情变得棘手，我想使用RabbitMQ队列中的消息.现在我知道在Rabbit上有一个MQTT插件( https://www.rabbitmq.com/mqtt.html ) . 但是，我似乎无法使Spark使用从pika产生的消息的示例工作. 例如，我在这里使用简单的wordcount.py程序( https://spark.apache.org/docs/1.2.0/strea ..

发布时间：2020-05-12 20:14:05 python apache-spark rabbitmq mqtt pika Python

中间件，用于为分布式系统构建数据收集和监视

我目前正在寻找一种好的中间件来构建监视和维护系统的解决方案.我们面临的挑战是监视，收集并维护由多达10,000个独立节点组成的分布式系统. 系统分为5-20个节点的组.每个组(作为一个团队)通过处理传入的传感器数据来生成数据.每个组都有一个专用节点(蓝色框)，充当该组的立面/代理，将组中的数据和状态公开给外界.这些群集在地理位置上是分离的，并且可以通过不同的网络连接到外部世界(一个可以在光纤 ..

发布时间：2020-05-11 22:12:51 monitoring rabbitmq zeromq data-distribution-service data-collection 其他开发

Mongo Operations挨饿

Mongo db操作在兔子mq使用者中变得越来越饥饿. rabbitConn.createChannel(function(err, channel) { channel.consume(q.queue, async function(msg) { // The consumer listens to messages on Queue A for suppose based on ..

发布时间：2020-05-11 21:50:47 javascript mongodb mongoose rabbitmq 前端开发

使用Docker链接时拒绝与RabbitMQ的连接

我有一个微服务应用程序，它有两个服务，还有一个兔子mq用作它们之间进行通信的消息队列.现在，我想将它们部署在docker上.我在docker-compose.yml文件中有以下代码: 版本:"3" 服务: rabbitmq: build: ./Rabbit hostname: "rabbitmq" container_name: "rabbitmq" ..

发布时间：2020-05-09 19:59:50 asp.net-core rabbitmq docker-compose microservices 其他开发

Rails:如何侦听/从服务或队列中提取消息?

大多数Rails应用程序的工作方式是等待客户端发出的请求，然后再发挥作用. 但是，如果我想将Rails应用程序用作微服务架构的一部分(例如)并进行一些异步通信(Serivce A将事件发送到Kafka或RabbitMQ队列中，而Service B-我的Rails应用程序-应该侦听此队列)，如何调整/启动Rails应用以立即侦听队列并从那里触发事件? (意味着初始触发不是来自客户端，而是来自应用程序 ..

发布时间：2020-05-09 19:55:18 ruby-on-rails rabbitmq apache-kafka microservices 其他开发

微服务为何使用RabbitMQ?

我没有找到现有的帖子问这个问题，但是对我错过的消息表示歉意. 我正在努力使我了解微服务，并遇到了使用RabbitMQ的文章.我很困惑为什么需要RabbitMQ.这些服务是否打算使用Web api与外界通信以及RabbitMQ彼此通信? 解决方案在微服务体系结构中，您有两种在微服务之间进行通信的方式: 同步-也就是说，每个服务直接调用另一个微服务，这导致服务之间的依赖性异步 ..

发布时间：2020-05-09 19:53:02 rabbitmq microservices 其他开发

NestJS-在微服务中将HTTP与RabbitMQ结合

我有一些微服务，这些服务通过API网关公开.网关负责处理身份验证和路由到系统中.网关后面的服务主要是简单的CRUD服务.每个服务都公开其自己的API，并且它们通过HTTP同步通信.所有这些服务，包括API-Gateway，都是“默认" NestJS应用程序. 让我们坚持“猫"的例子.每当Cat-Service更新或创建新的Cat时，我都希望使用CatCreatedEvent或CatUpdat ..

发布时间：2020-05-09 19:52:15 node.js events rabbitmq microservices nestjs 其他开发

rabbitmq相关内容