rabbitmq相关内容

在ASP.NET Core应用程序中设置RabbitMQ使用者

我有一个ASP.NET Core应用程序,我想在其中使用RabbitMQ消息。 我已经在命令行应用程序中成功设置了发布者和使用者,但是我不确定如何在Web应用程序中正确设置它。 我正在考虑在 Startup.cs ,但是当然它会在启动完成后就消失。 如何通过Web应用程序以正确的方式初始化使用者? 解决方案 使用单例模式供消费者/听众在应用程序运行时保留它。使用 IApp ..
发布时间:2020-05-31 19:27:25 C#/.NET

等待一个RabbitMQ消息超时

我想向RabbitMQ服务器发送一条消息,然后等待答复消息(在“答复”队列中)。当然,我不想永远等待,以防处理这些消息的应用程序关闭-需要超时。听起来这是一项非常基本的任务,但我找不到解决方法。我现在同时遇到 py-amqplib 和 RabbitMQ .NET客户端。 我最好的解决方案到目前为止,已经使用 basic_get 和 sleep 进行了轮询,但这很丑陋: def _wa ..
发布时间:2020-05-30 20:05:37 C#/.NET

用于RabbitMQ的REST API

有没有办法将数据从$ .ajax发送到RabbitMQ? 我的应用程序由数千个Web客户端(用js编写)组成和WCF REST服务,现在我想弄清楚如何为我的应用程序创建可扩展点。这个想法是要有一个Rabbitmq实例来接收来自放置在一侧的js客户端的消息,以及一个WCF Workflow Services实例,该实例正在从队列中接收挂起的消息。 I知道AMQP和HTTP是完全不同的东西 ..
发布时间:2020-05-30 19:52:40 C#/.NET

气流:任务排队但未运行

我是气流的新手,正在尝试设置气流以运行ETL管道。我能够安装 气流 postgres celery rabbitmq 我能够测试运行turag dag。当我尝试调度作业时,调度程序可以将其拾取并排队,这些作业可以在UI上看到,但任务未运行。有人可以帮我解决这个问题吗?我相信我在这里缺少最基本的气流概念。以下是airflow.cfg 这是我的配置文件: [核心] ..
发布时间:2020-05-29 21:14:40 其他开发

限制通过IP访问RabbitMQ

我通过docker镜像在包括管理插件和rabbitmq_auth_backend_ip_range插件的机器上安装了Rabbit mq.我想限制对端口5671/2和15672的访问,以仅允许某些IP访问它们. 由于15672是Web界面,因此我目前没有解决方案.有什么想法吗? 对于5671/2(哪个是安全的?),我想使用插件rabbitmq_auth_backend_ip_range, ..
发布时间:2020-05-29 01:39:40 数据库

RabbitMQ使用哪些端口?

RabbitMQ Server使用哪些端口或需要在防火墙上为节点集群打开哪些端口? 我的/usr/lib/rabbitmq/bin/rabbitmq-env设置为低于我的需要(35197). SERVER_ERL_ARGS="+K true +A30 +P 1048576 \ -kernel inet_default_connect_options [{nodelay,true} ..
发布时间:2020-05-29 01:32:18 其他开发

Play Framework通过Rabbit MQ发送消息

有人在Play Framework上使用Rabbitmq吗? 我有一个使用Play Framework用Scala编写的AI.我有一个处理nosql数据库的平均堆栈. 我想通过Rabbitmq向该AI发送JSON消息. 我已经可以使用nodejs和Rabbitmq进行操作,但是现在我想连接游戏,可能需要您的帮助. 有人在Rabbitmq上玩过游戏或有任何实际建议吗? 谢谢! ..
发布时间:2020-05-28 02:48:04 其他开发

Akka的语言和产品替代品有哪些?

现在我正在查看 Play框架,并且非常喜欢.在Play提供的功能中,广为宣传的部分之一是 Akka . 为了更好地了解Akka以及如何正确使用Akka,您能告诉我其他语言或产品的替代方案是什么吗? RabbitMQ 与之相比如何?有很多重叠吗?一起使用它们是否可行?在什么用例中? 解决方案 最好的起点是很棒Akka官方文档.我认为最接近Akka的产品/框架是 erlang 语言 ..
发布时间:2020-05-28 01:59:33 其他开发

如何停止rabbitmq服务器

我正在尝试启动一个节点应用程序,但我认为Rabbitmq会妨碍工作. 类似于此线程:$ ps aux | grep erl rabbitmq 1327 0.0 0.0 2376 300 ? S Dec13 0:00 /usr/lib/erlang/erts-5.8.5/bin/epmd -daemon rabbitmq 1344 0.0 0.3 59560 14888 ? Sl Dec13 ..
发布时间:2020-05-27 20:35:18 其他开发

PHPUnit RabbitMQ:创建连接功能的编写测试

我正面临以下问题.我编写了一个函数,该函数根据给定的参数创建连接对象(AMQPConnection).现在我要编写相应的单元测试.我只是不运行RabbitMQ代理就不知道该怎么做.这是有问题的功能: public function getConnection($hostKey, array $params) { $connection = null; try { ..
发布时间:2020-05-27 19:55:09 PHP

如何延误? -php-amqplib

我想知道如何延迟使用Amqpphplib. 我使用了这个很棒的咖啡脚本教程: https://github.com/jamescarr/rabbitmq-scheduled-delivery 但它似乎不适用于PHP-amqplib. 该消息按照我的意愿过期,但是似乎"x-dead-letter-exchange"无法完成工作.我使用RabbitMQ管理控制台,可以实时查看所 ..
发布时间:2020-05-27 02:53:48 PHP

消费未确认的RabbitMq消息

我创建了一个简单的发布者和一个使用basic.consume在队列上进行订阅的使用者. 我的使用者在作业正常运行时会确认消息.每当遇到异常时,我都不会确认该消息并提早返回.仅已确认的消息从队列中消失,因此可以正常工作. 现在,我希望使用者重新获取失败的消息,但是重新使用这些消息的唯一方法是重新启动使用者. 我该如何处理这个用例? 设置代码 $channel = new A ..
发布时间:2020-05-27 02:33:56 PHP

PHP致命错误:找不到类"AMQPConnection"

我已经看过这个问题.这表明未安装AMQP PECL扩展.但是,我已经成功安装了RabbitMQ和内置的PECL AMQP扩展.以下是phpinfo()的输出. 您可以清楚地看到,AMQP已正确加载.但是,当我尝试建立连接时,它显示 PHP致命错误:找不到类'AMQPConnection'.下面是代码. $connection = new AMQPConnection(); 这是输出 ..
发布时间:2020-05-27 02:04:01 PHP

PHP守护程序/工作人员环境

问题:我想实现几个php-worker进程,这些进程正在MQ服务器队列上侦听异步作业.现在的问题是,简单地在服务器上以守护程序的形式运行此进程并不能真正赋予我对实例的任何级别的控制(负载,状态,锁定)……除非可能是转储ps -aux. 因此,我正在寻找某种可以在系统(进程)级别或更高层(某种Java风格的应用服务器)上监视和控制实例的运行时环境 有指针吗? 解决方案 以下是一些有用的 ..
发布时间:2020-05-24 20:53:25 PHP

Web API控制器方法执行到结束.没有HTTP响应.挂起

我正在寻找一种调试这种情况的方法.我已经在Fiddler中验证,根本没有HTTP响应.需要明确的是,据我了解,控制器方法不应简单地挂起,也不例外.我已经证实Fiddler缺乏回应.该方法返回有效的对象,并通过逐步执行代码直至最终的return语句进行验证. 这与原始问题的不同之处在于,命中了控制器方法,而不是以前的方法.最初的问题解释了这样做的原因. ASP.NET Web Api.控制器未 ..
发布时间:2020-05-23 19:02:31 C#/.NET

Rabbit-MQ服务器出错

我正在尝试使用devstack在Ubuntu 12.04上设置OpenStack.现在,我得到的错误是: Setting up rabbitmq-server (2.7.1-0ubuntu4) ... Starting rabbitmq-server: FAILED - check /var/log/rabbitmq/startup_{log, _err} rabbitmq-server. ..
发布时间:2020-05-21 18:31:30 其他开发

用于实时在线游戏的amqp或xmpp

其中哪些技术套件适用于多用户在线游戏项目. 项目要求: 1.能够在任何给定时间处理2k-5k用户. 2.适用于iPhone和Android的客户端库(本机,没有javascript). 3.适用于Microsoft Windows(最重要)的客户端库,也适用于mac os x和linux的客户端库. 4.专门用于mod开发的好的文档 5.项目不是开源的.因此,只能使用具有适当许可的库. 我也 ..
发布时间:2020-05-20 21:43:23 其他开发

RabbitMQ错误超时

我已经设置RabbitMQ来解析来自外部API的大约20.000个请求,但是几分钟后它一直保持超时.确实可以正确解析20.000个请求中的2000个. 日志文件显示: =INFO REPORT==== 16-Feb-2016::17:02:50 === accepting AMQP connection (127.0.0.1:33091 -> 127.0.0.1: ..
发布时间:2020-05-17 20:56:28 PHP

RabbitMQ春季启动会话错误

尝试将RabbitMQ队列消息传递到我的Spring Boot应用程序时遇到问题.我正在运行spring data 4,并且正在使用Neo4j作为数据库.我能够从RabbitMQ队列接收并解析JSON字符串到Spring Boot应用程序.这是接收器进程的线程更改: 14:19:17.811 [main] INFO o.s.b.c.e.t.TomcatEmbeddedServletConta ..
发布时间:2020-05-17 00:24:32 其他开发