tomener/php-nsq

PHP 的 NSQ 发布者

维护者

详细信息

github.com/tomener/php-nsq

主页

源代码

安装: 18

依赖: 0

建议者: 0

安全: 0

星标: 0

关注者: 1

分支: 5

0.2.5 2020-04-10 06:26 UTC

Requires

Requires (Dev)

MIT 0988b91fa56d5086855b944b7af558d6a8c21a20

publishernsqpub

This package is auto-updated.

Last update: 2024-09-10 17:48:26 UTC

README

此库仅用于向 NSQ 节点发布消息。需要标准的 PHP 套接字扩展。

安装

添加到 composer.json

{
    "require": {
        "tomener/php-nsq": "~0.2.0"
    }
}

使用示例

<?php

include __DIR__ . '/vendor/autoload.php';

use Nsq\NsqPool;
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);