-
2 votesanswersviews
来自外部服务的Laravel队列侦听器
我有一个用Laravel编写的遗留API,我试图从RabbitMQ队列发布数据 . 我正在使用第三方库将RabbitMQ集成到本机Laravel Queue架构中 . 哪个工作正常,并且在侦听器控制台命令运行时正确处理消息 . 但是,当我传递以下事件时,包括队列处理程序所需的作业和数据键... {"job":"SixtyFiveContrib\\Jobs\\Creat... -
1 votesanswersviews
Laravel Queue Worker,RabbitMQ和远程生成的作业
我将通过承认轻微的睡眠剥夺来作为序言 . 设置如下: API Endpoint (Server A) 接收传入呼叫,并将其添加到RabbitMQ服务器(服务器B)上的特定队列 . RabbitMQ (Server B) 只是一个RabbitMQ队列服务器 . 没有更多,没有更少 . Laravel Installation (Server C) 是我们实际的Laravel安装,它用于在特定队列中查... -
1 votesanswersviews
在haproxy背后的RabbitMQ消费者的连接错误
我正在使用rabbitmq集群 . 我的消费者通过haproxy连接了这个集群 . 消费者提出了通过haproxy连接的以下异常 . 如果直接连接到节点的消费者不会引发任何异常 . 2013-01-08 16:25:09,745 WARN | SimpleAsyncTaskExecutor-1 | o.s.amqp.rabbit.listener.SimpleMessageListenerCont... -
2 votesanswersviews
什么是在RabbitMQ的C#客户端中优雅地停止消息消费的优雅方法?
我正在设置一个标准的独立线程,在C#中监听RabbitMQ . 假设在线程中侦听的方法如下所示: public void Listen() { using (var channel = connection.CreateModel()) { var consumer = SetupQueues(channel); while (true) ... -
2 votesanswersviews
rabbitmq连接最佳实践我们是否在发布者中保持持久连接
通常,SQL连接的最佳实践是打开连接,执行查询并配置连接 . 但是,基于AMQP的队列服务器(如RabbitMQ)的推荐做法是什么 . 应用程序是否需要维护与RabbitMQ服务器的持久连接,或者为发布方发送的每条消息打开和关闭连接 . public static void Main(string[] args) { var factory = new Connection... -
1 votesanswersviews
如何断开连接,然后使用EasyNetQ从RabbitMQ重新连接?
我处于需要断开与RabbitMQ的连接并使用EasyNetQ重新连接的情况 . 我是通过处理文档中描述的IBus来做到这一点的 . https://github.com/EasyNetQ/EasyNetQ/wiki/connecting-to-rabbitmq “要关闭连接,只需处理总线......这将关闭EasyNetQ使用的连接,通道,消费者和所有其他资源 . ” 但是当我打电话来创建一个新的... -
0 votesanswersviews
哪些pub / sub协议具有基于订户的数据传播?
我正在尝试评估不同的pub / sub消息传递协议的横向扩展能力,而不会产生不必要的交叉聊天 . 我的架构将具有连接Web套接字客户端的NodeJS服务器 . 我计划使用一致的基于哈希的路由器根据他们感兴趣订阅的主题将客户端引导到服务器 . 这意味着对于给定主题,只有一部分服务器将具有订阅该主题的客户端 . 然后将消息发布到pub / sub代理,该代理负责将该数据扇出到具有订阅者的服务器 . 我... -
1 votesanswersviews
AMQP-CPP:TCP处理程序中的管道错误
不幸的是,在我的项目中,我总是在事件处理程序中的onError函数中出现错误消息“Broken pipe” . 不幸的是,我从未进入onConnected状态 . 事件处理程序中的监视器Funktion使用Flag AMQP :: readable调用两次 . 之后,调用它时没有设置标志,这是我的管道坏了的时候 . 这是我在代码中所做的 . 首先我打开连接: int Communicator_Ra... -
0 votesanswersviews
Spring Cloud Config Server(Spring Boot应用程序)上刷新了[]的空列表
在我的Spring Cloud配置服务器pom.xml中 <parent> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-parent</artifactId> <version>2.0.0.REL... -
0 votesanswersviews
Airflow 1.9 - 任务卡在队列中
来自PyPy的最新Apache-Airflow安装(1.9.0) Set up includes: Apache-Airflow Apache-Airflow [芹菜] RabbitMQ 3.7.5 芹菜4.1.1 Postgres 我安装了3台主机 . Host #1 Airflow Webserver 气流计划程序 RabbitMQ服务器 Postgre... -
0 votesanswersviews
如何构建 Cloud 应用程序(AWS或IBM)?
我正在考虑与我的朋友一起构建SaaS . 我们已经为特定行业提供了时间序列软件 . 我们的客户应该提取时间序列数据并以适当的格式获得响应 . 应用程序应该为我们提供低延迟,高吞吐量和灵活的数据处理弹性 . 我对Python,MongoDB,RabbitMQ解决方案感兴趣 . 我想知道这些步骤是如何工作的 . 客户端将数据导出到 Cloud 端 将专有格式转换为文本文件 写入MongoD... -
3 votesanswersviews
从检查点恢复Apache Flink作业
我正在使用Apache Flink RabbitMQ堆栈 . 我知道有机会手动触发保存点并从中恢复作业,但问题是Flink在成功检查点之后确认消息,并且如果要进行保存点和恢复状态,则会丢失上次成功保存点和上次成功检查点之间的所有数据 . 有没有办法从检查站恢复工作?这将解决在不可重放数据源(如rabbitmq)的情况下丢失数据的问题 . 顺便说一句,如果我们有检查点的所有开销,为什么不让用户使用它... -
162 votesanswersviews
从RabbitMQ中删除所有队列?
我安装了 rabbitmqadmin 并能够列出所有的交换和队列 . 如何使用 rabbitmqadmin 或 rabbitmqctl 删除所有队列 . -
1 votesanswersviews
如何调试rabbitmq ldap代码?
我正在尝试使用openldap for rabbitmq auth . 但是在监视openldap日志时,它总是有错误信息 . 计划通过替换ebin文件将调试代码插入rabbitmq的源代码中 . 两个问题: 如何使用shell输入启动rabbitmq-server,因此可以在线调试 . 默认情况下,ps -ef显示rabbitmq以 noshell 开头 . 怎么改呢? yus-iMac:e... -
1 votesanswersviews
创建从RabbitMQ到ActiveMQ的连接
我有一个ActiveMQ服务器的详细信息,我想连接并查看可用的数据 . 我想使用RabbitMQ(CloudAMQP) . 我已阅读文档,但我无法弄清楚如何 Build 此连接? 我的连接细节如下: host = 'ssl://api.myreports.com:61613' user='myuser' password='mypassword' topicname = '/topic/myTop... -
0 votesanswersviews
芹菜不会连接到rabbitmq经纪人为kubernetes
我目前正在尝试在Kubernetes(和minikube)上使用celery,rabbitmq和flower部署基本任务队列和前端 . 我在这里关注这个例子: https://github.com/kubernetes/kubernetes/tree/release-1.3/examples/celery-rabbitmq 我可以按照指示让一切顺利;但是,当我在 ./celery-app-add ... -
1 votesanswersviews
nova-compute服务状态已关闭
我有一个一体化的设置,我的控制器和计算服务在同一个节点上运行 . 所有我的新星和其他相关服务都启动并运行 . 但是,当我尝试启动一个实例时,nova-compute进程的状态会变低 . 因此,实例停留在产卵状态 . > [root@localhost nova(keystone_admin)]# nova service-list > +----+------------------+... -
1 votesanswersviews
Connection拒绝尝试使用Spring从Cloud Foundry上读取RabbitMQ Queue
我正在尝试使用RabbitMQ从一个应用程序发布消息并在另一个应用程序中接收它们 . 这些应用程序托管在Cloud Foundry上,并且两者都绑定到RabbitMQ的同一个实例 . 我可以从第一个应用程序发送消息到队列,但在我的第二个应用程序中,它使用@RabbitListener和@RabbitHandler来侦听此队列,我收到连接被拒绝错误 . 它虽然在我的本地RabbitMQ实例上运行良好... -
1 votesanswersviews
在2个本地Ubuntu实例上运行2个RabbitMQ worker和2个Scrapyd守护进程,其中一个rabbitmq worker不工作
我目前正致力于构建"Scrapy spiders control panel",我正在测试[分布式多用户Scrapy蜘蛛控制面板] https://github.com/aaldaber/Distributed-Multi-User-Scrapy-System-with-a-Web-UI上提供的现有解决方案 . 我试图在我的本地Ubuntu开发机器上运行它,但有 scrapd ... -
0 votesanswersviews
连接RabbitMQ |皮卡| Kubernetes
我有一个kubernetes集群正在运行 . 在这里我有一个作为pod运行的python应用程序 . 这个应用程序正在与 rabbitmq 交谈,这也是同一群集的其中一个 . 因此整个连接使用内部IP完成 . 问题是我有一个rabbitmq服务,所以我提供服务IP连接 . 它看起来像这样(与鼠兔) credentials = pika.PlainCredentials(rabbituser, ra... -
5 votesanswersviews
Spring作为Broker Relay使用外部Message Broker
我想使用 Spring Messaging 为我的webapp为已登录用户创建实时通知系统 . 我将 AbstractWebSocketMessageBrokerConfigurer 定义如下: @Override public void registerStompEndpoints(StompEndpointRegistry registry) { registry.addEndpoin... -
3 votesanswersviews
如何保证Java / Spring应用程序上的WebSocket消息顺序[重复]
这个问题在这里已有答案: SockJS receive stomp messages from spring websocket out of order 3个答案 我们目前正在使用Spring的SimpMessagingTemplate将WebSocket消息从服务器发送到客户端 . 我们注意到有时收到的邮件不按规定 . 例: (Autowired) SimpMessagingTemplat... -
1 votesanswersviews
如何使用RabbitTemplate模仿SimpMessagingTemplate.convertAndSendToUser?
所以我一直在阅读有关RabbitMQ代理的Spring Message Relay(Spring Messaging stuff)功能 . 我想要实现的目标如下: 有一个服务(1),它充当rabbitmq和浏览器之间的消息中继 . 这现在工作正常 . 我正在使用MessageBrokerRegistry.enableStompBrokerRelay来做到这一点 . 在后端有另一个服务(2),它将一... -
0 votesanswersviews
Spring Boot - RabbitMQ - 处理经纪人失败的场景
我们在项目中使用rabbitmq进行消息传递 . 这主要用于审计日志记录 . 我们试图检查我们的应用程序如何响应某些故障情况 . 例如,如果RabbitMQ关闭,消费者会不断尝试与rabbitmq Build 连接并失败 . 如果rabbitmq停机,消费者有没有办法停止尝试?以类似的方式,当代理停止时,发布者如何停止尝试向队列发送消息?断路器是我们可以考虑的选择之一吗? -
3 votesanswersviews
具有HA代理的Spring STOMP Broker Relay RabbitMQ集群面向每个负载 balancer
我正在设计一个系统,其中从设备生成的大量实时数据最好通过websockets传输给用户 . 我已经决定使用Spring STOMP Websockets,因为它更快地设置,理解并且像RabbitMQ和Security一样支持开箱即用 . 而且因为计划是将Spring用于另一个REST API,所以Spring作为技术堆栈的选择 . RabbitMQ是我决定使用的消息代理 . 但是,我找不到关于如... -
1 votesanswersviews
spring Websockets与tomcat服务器和兔子mq作为消息代理stomp - 负载测试连接失败
使用带有stcat的tomcat服务器和rabbit mq的spring Websockets作为消息代理 . 当试图在没有RabbitMQ作为中继代理的情况下运行时,它允许最大约10000个连接 . (基于tomcat允许的最大连接数限制) 当尝试使用RabbitMQ作为中继代理(在AWS中托管 - 单个实例)时,在进行负载测试时,在一定数量的连接(4000)之后失败 . (在RabbitM... -
0 votesanswersviews
Celery错误:收到'task'类型的未注册任务
我的芹菜日志中出现以下错误: [2018-05-04 23:33:42,186: ERROR/MainProcess] Received unregistered task of type 'test_post'. The message has been ignored and discarded. Did you remember to import the module containin... -
2 votesanswersviews
什么属于DLQ /无效消息队列?
关于允许应用程序拒绝哪种消息,是否有良好的最佳实践? 我的理解是,所有无法处理的消息都应该被拒绝到死信队列 - 无论问题是语法错误还是消息中的语义错误,或者应用程序暂时无法处理消息(例如,因为数据库刚刚下降) . 当然 - 如果应用程序已经预先知道它将无法处理消息(DB down),它应该停止接受消息 . 那么共同的理解/最佳实践是什么? -
0 votesanswersviews
Erlang:如何使用指定位置安装Erlang for Windows
我想安装Erlang for Windows . Erlang提供Windows安装程序,但安装程序会将Erlang安装到固定文件夹“Program Files”中 . 我需要将Erlang安装到可选位置 . 请告诉我如何使用我想要安装的路径安装Erlang for Windows . -
3 votesanswersviews
如何为RabbitMQ / Erlang使用多个配置文件
我正在尝试设置一个基于Spring的Java应用程序,该应用程序使用本地安装的RabbitMQ服务器在节点之间传递消息 . 正如你们中的一些人所知,rabbitmq.config文件可用于配置各种参数,并由运行Rabbit服务器的底层Erlang节点加载 . 我的问题是我要求某些配置需要 static ,有些需要 dynamic ,具体来说,我需要能够在用户交互的结果中不时重新配置在Rabbit服...