Jun

在swoole中，作为常驻进程，如何使用该扩展呢？

7

最近使用php swoole做项目，启动一个常驻进程，需要把接口日志发送到kafka，问题如下： 1、在github上的示例，异步和同步的生成者方式每次都是new一个生成者。那么在常驻进程中，怎么实现一个生产者连接池，不需要每次都是new一个生成者。 2、使用异步生成者方式进行测试，发现每次会发送多次数据到kafka，这个是怎么回事呢？ 3、使用同步方式，把kafka生产者赋给一个类属性，这样不需要每次都去new一个生产者，但是发现会报如下的错误： Fatal error: Uncaught Kafka\Exception\Socket: After 4 attempts could not write 444 bytes to stream, completed writing only 0 bytes in kafka/nmred/kafka-php/src/Kafka/SocketSync.php:380