php-amqplib

    2热度

    1回答

    在Symfony中执行RabbitMQ使用者时出现“读取数据时出错”

    我有一个RabbitMQ容器和一个PHP 7容器，其中包含Symfony 3.1.x项目，该项目使用OldSoundRabbitMqBundle执行RabbitMQ使用者。 当运行这个命令执行test消费者： bin/console rabbitmq:consumer -w test 我收到以下错误： [PhpAmqpLib\Exception\AMQPIOException] Error r
    docker rabbitmq symfony php-amqplib 2016-09-22

    0热度

    1回答

    兔子MQ消费者如何工作？

    我有两个关于RabbitMQ的消费者问题（接收器）： 我如何定义（静态地从队列中）什么是注册到某一个队列的消费者，因此，如果一个消费者下消息在消费者再次上涨之后仍然会交付，还是有其他方法可以实现这一目标？ 消费者如何连接到尚未创建的队列，在rabbitmq教程中，我可以在生产者之前调用消费者，它仍然可以工作，有人可以请解释这是如何工作的吗？ 感谢
    php rabbitmq message-queue php-amqplib 2016-06-23

    1热度

    1回答

    的RabbitMQ无法获得与心跳我所观察到的RabbitMQ“卡住”与UNACKED消息PHP-amqplib

    工作。队列显示消费者不再存在，我假设发生的事情是RabbitMQ继续向消费者传递消息。它们表现为不断增加的未消息信息数量。我使用php-amqplib在PHP中执行此操作。 我可以通过杀死消费者进程（命令行上的控制-C）产生的问题。 我试图指定3秒的心跳，并试图保持活跃真假两。有了心跳，消费者最终将失败： Exception fwrite(): send of 573 bytes failed w
    rabbitmq php-amqplib 2016-08-17

    1热度

    1回答

    通过RabbitMQ发送数组

    如何使用RabbitMQ发送消息数组？ 我不想单独发送每封邮件。 对于examlple： ch.publish(ex, '', new Buffer('hello world')); 我怎么能使用somethink像： ch.publish(ex, '', new Buffer([msg1, msg2, msg3...])); 谢谢！
    node.js rabbitmq amqp node-amqp php-amqplib 2015-09-15

    10热度

    2回答

    RabbitMQ错误超时

    我已经设置了RabbitMQ来解析来自外部API的一些20.000个请求，但它在几分钟后保持超时。它确实可以在总共20,000个请求中正确解析大约2000个。 日志文件说： =INFO REPORT==== 16-Feb-2016::17:02:50 === accepting AMQP connection <0.1648.0> (127.0.0.1:33091 -> 127.0.0.1:56
    php ubuntu nginx rabbitmq php-amqplib 2016-02-16

    0热度

    1回答

    PHP AMQP消费者在一段时间后没有回应

    我在这里遇到了一个PHP amqp消费者的小问题，它在一段时间后停止工作。您可以在下面看到我的silex命令。我也尝试过使用心跳和Keepalive配置来处理断开的网络连接，但不会改变。什么可能是消费者不读队列消息的原因？脚本没有退出，它似乎在睡觉。 <?php use Symfony\Component\Console\Input\InputInterface; use Symfony\C
    php rabbitmq amqp silex php-amqplib 2016-04-08

    1热度

    2回答

    访问队列绑定之前发送的交换消息

    我有一个关于third RabbitMQ tutorial的问题。我试图实现类似的东西，除非不能保证消费者在生产者向交易所发送消息时运行。 所以，我有我的制片人，其消息发布给扇出交换： $channel->exchange_declare('my_exchange', 'fanout', false, false, false); $channel->basic_publish('my_mess
    php rabbitmq php-amqplib 2016-10-25

    1热度

    1回答

    使用php-amqlib从RabbitMQ中读取消息不起作用

    我正在使用php-amqplib与PHP和RabbitMQ进行客户端 - 服务器通信。 我有一个生产者脚本，看起来像工作正常，但我的消费者没有收到任何东西。 我用sudo rabbitmqctl list_queues检查了队列中的条目，每次运行生产者后，计数器都会增加。 我的消费者没有任何PHP错误，看起来像等待消息。 什么看起来不错，它会在启动时运行回调脚本一次，并收到空的传入消息 - 而不会
    php rabbitmq amqp php-amqplib 2017-08-23

    4热度

    1回答

    ：

    我使用vladimir-yuldashev/laravel-queue-rabbitmq库流明项目中使用RabbitMQ的队列“PhpAmqpLib \异常\ AMQPRuntimeException通道连接被关闭”错误与流明队列。 队列功能工作正常，但我看到下面吨的错误在我的日志文件。 lumen.ERROR: PhpAmqpLib\Exception\AMQPRuntimeException:
    laravel events rabbitmq lumen php-amqplib 2017-07-05

    0热度

    1回答

    Json在RabbitMQ中解析或传递标头

    我想将多值传递给由RabbitMQ通过PHP提供的队列。这是一个手机号码和内容的短信发送者。 是更好地这两个参数发送一个JSON字符串排队的有效载荷和对消费者的身边收杆JSON或，发送手机号码作为头参数和内容的有效载荷和使用get("application_headers")和getNativeData消费者的身边，用手机数？ 哪种方式有更好的性能？
    php json rabbitmq php-amqplib 2016-07-26
最新问题