PHP code example of tomener / php-nsq

1. Go to this page and download the library: Download tomener/php-nsq library. Choose the download type require.

2. Extract the ZIP file and open the index.php.

3. Add this code to the index.php.

    
        
<?php
require_once('vendor/autoload.php');

/* Start to develop here. Best regards https://php-download.com/ */

tomener / php-nsq example snippets

 php


sqPool;
use Nsq\Socket\PhpSocket;
use Nsq\Message\JsonMessage;

$nsq = new NsqPool(
    new PhpSocket('127.0.0.1', 4150),
    new PhpSocket('127.0.0.1', 4170)
);

$msg = [
    'nickname' => 'tomener',
    'sex' => 1
];

//single publish
$nsq->publish('topic_name', new JsonMessage($msg));

//defer publish
$nsq->publish('topic_name', new JsonMessage($msg), 60000); //延迟60秒

//multiple publish
$msgs = [
    new JsonMessage(['nickname' => 'tomener', 'sex' => 1]),
    new JsonMessage(['nickname' => 'lucy', 'sex' => 2]),
];
$nsq->multiPublish('topic_name', $msgs);