yunnian/php-nsq

I ask you to open a previously closed problem

pecherskiy-v opened this issue · 5 comments

I am attaching a link to the problem and description #56

child process pids 2782 be terminated, trying reload 
last all pid:
    2782
child process pids 2783 be terminated, trying reload 
last all pid:
    2783
# php -v
PHP 8.0.12 (cli) (built: Oct 21 2021 16:26:22) ( NTS )
Copyright (c) The PHP Group
Zend Engine v4.0.12, Copyright (c) Zend Technologies
    with Xdebug v3.1.1, Copyright (c) 2002-2021, by Derick Rethans
# php --ri nsq 

nsq

nsq support => enabled
version => 3.5.1
author => zhenyu.wu[email:wuzhenyu@kuangjue.com]

nsqd

command:
    - /nsqd
    - -lookupd-tcp-address=nsqlookupd:4160
    - -broadcast-address=nsqd

nsqlookupd

command:
    - /nsqlookupd
$nsqLookupd = new \NsqLookupd("nsqlookupd:4161");

$this->nsq->subscribe($nsqLookupd, $nsqlConfig, function ($msg,$bev) use ($output) {
    $output->writeln($msg->payload);
    $output->writeln($msg->attempts);
    $output->writeln($msg->messageId);
    $output->writeln($msg->timestamp);
});

install:

pecl install nsq

- /nsqd
- -lookupd-tcp-address=nsqlookupd:4160
- -broadcast-address=nsqd

$nsqLookupd = new \NsqLookupd("nsqlookupd:4161");

---------------------

Try it with ip everywhere.

registered the IP address directly, does not work.

$nsqlConig = [
            "topic" => Constant::TOPIC,
            "channel" => Constant::CHANNEL,
            "rdy" => 2,                //optional , default 1
            "connect_num" => 1,        //optional , default 1   
            "retry_delay_time" => 5000,  //optional, default 0 , if run callback failed, after 5000 msec, message will be retried
            "auto_finish" => true, //default true
        ];
        $nsqLookupd = new \NsqLookupd("10.***.**.248:4161"); //the nsqlookupd http addr

endless loop organized by \React\EventLoop\Loop

self::$loop = Loop::get();

...

self::$loop->run();

And there are no memory limits in the test environment.