php-amqplib

    1热度

    1回答

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

    4热度

    2回答

    我想检索一个遗留的xml文件,操作并保存它。 这里是我的代码: from xml.etree import cElementTree as ET NS = "{http://www.somedomain.com/XI/Traffic/10}" def fix_xml(filename): f = ET.parse(filename) root = f.getroot()

    -3热度

    1回答

    可以有些机构提供帮助我使用TFDTable.FireDac对我来说是全新的。我在delphi 2010中使用TTable作为内存数据库。所以我想在xe7中使用TFDTable进行临时保存。

    0热度

    1回答

    在sql服务器中,我创建了一个表与列ID作为int与身份,第二个是名称varchar,我创建了一个proc插入和我写入语句,插入后记录我想插入的记录ID为我使用@ @identity它正在工作,但奇怪的@@身份显示更多的行,但在表中,很多记录没有减少recrords。我的proc是 alter proc usp_test123 as begin set nocount o

    1热度

    2回答

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

    0热度

    1回答

    我试图使用UPDATE更新我的表(商店)中的3个不同的列。我想添加一个openingTime,closingTime和phoneNumber ...但我希望它们通过storeId添加,该表已经存在于表中。我是否需要根据storeId对每个条目进行单独调用?或者是否可以对表进行一次调用并遍历每个storeId? 这是我到目前为止。 var arraythatcontainsEverything =

    1热度

    1回答

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

    4热度

    1回答

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

    2热度

    1回答

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

    3热度

    1回答

    我爬行和刮android市场的网站。 但我无法从网站 下载应用程序的次数,因为它不提供有关下载的信息,但它提供了排名。 那么,有谁知道如何获得下载次数?