利用RabbitMQ来做一个RPC的客户端和服务端。
输出斐波那契数列为例子。
rpc_server.php:
```php
...
发布日期:
2018-11-15
分类:
其他
浏览量:
5302
Routing那一文是日志系统还是有不足的地方,如果我们想既基于选择和发送消息的来源来接收日志呢?
比如像Linux的`syslog`一样,可以基于消息的级别(info/warn..),产生消息的来源(auth/cron)来记录日志。
要实行这样的功能,就需要`topic`类型的exchange了。
`topic`类型的exchange,`routing_key`参数值不能随便设置,需要是一个点(`.`)分隔的词列表,词可以随意设置,一般是使用有意义的内容。比如`stock.usd.nyse`,数据长度是最大是255个字符。
`binding key`也是同样的格式,可以有两个特殊的字符:
- `*`:匹配单个词。
- `#`:匹配0个或多个词。
比如`...
发布日期:
2018-11-15
分类:
其他
浏览量:
4605
接着上篇发布-订阅的日志记录,如果只订阅消息的子集,比如,只记录错误日志到硬盘,全部的消息打印出来,那么就需要用到这里要讲的内容了。
`exchang`的绑定操作可以传递一个叫`routing_key`的额外参数,这里把它称为`binding key`。
```php
$binding_key = 'black';
$channel->queue_bind($queue_name, $exchange_name, $binding_key);
```
`binding key`依赖于`exchange`的类型,`fanout`类型是会忽略这个值的。
在日志系统里面,如果需要根据消息级别过滤消息,就是不同的订阅者收到不同级别的错误日志消息会有不同的处理方式。
...
发布日期:
2018-11-15
分类:
其他
浏览量:
4926
一个消息分发给多个消费者,这就叫做发布-订阅模式。
作为示例,这里构建一个日志系统,由两部分组成,一个是发送日志消息,另一个是接收和打印。
**exchange**
`exchange`就是接收生产者的消息,然后推送给队列的一个东西,类似邮局。
`exchange`有几种类型,`direct`, `topic`, `headers` 和`fanout`。
不同的`exchange`类型会有不同的行为,各种类型的使用在后续文章会有介绍,这里我们先只关注最后一种。
`$channel->exchange_declare('logs', 'fanout', false, false, false);`
`fanout`类型是广播消息到所有已知的队列。
...
发布日期:
2018-11-13
分类:
其他
浏览量:
3326
可以使用`composer init`来初始化一个测试项目,然后用`composer require php-amqplib/php-amqplib`来引入`RabbitMQ`开发包,然后就可以进行以下测试了。
下面是一个简单的生产者和消费者代码。
如果运行多个消费者,生产者的消息会通过轮训的方式平均分配给消费者。
生产者(消息发送者):
**producer.php**
```php
...
发布日期:
2018-11-04
分类:
其他
浏览量:
3551
官网下载二进制包,或者用对应系统的仓库安装就可以了。
安装好后默认服务是启动的,可以使用下列命令查看状态:
`service rabbitmq-server status`或者`systemctl status rabbitmq-server`。
服务是以`rabbitmq`用户运行的。
需要打开的端口:
- 4369:RabbitMQ and CLI 工具用来节点发现的。
- 5672,5671:客户端AMQP通信端口。
- 25672:节点间和CLI工具的通信端口,这个端口的是动态的,AMQP端口+20000计算而来。如果不需要外部通信,不需要公开端口。
- 35672 - 35682:用于CLI工具和节点间通信用。动态分配的,计算方法是上的端口号+10000 ...
发布日期:
2018-11-04
分类:
其他
浏览量:
4006