我刚刚为 Ratchet WAMP + 高速公路版本 1 做了一个聊天 hello world。
如果你想看的话,这里有完整的源代码
JavaScript客户端发送聊天消息:
function click_send_btn() {
var json_data = {
"message": $.trim($("#input_message").val())
};
sess.publish("send_message", json_data, true);
}
PHP Ratchet 服务器发布消息:
public function onPublish(\Ratchet\ConnectionInterface $conn, $topic, $event, array $exclude, array $eligible) {
switch ($topic) {
case 'http://localhost/enter_room':
$foundChater = $this->allChater[$conn];
$newChaterName = $event['username'];
$foundChater->setChatName($newChaterName);
break;
case 'send_message':
$foundChater = $this->allChater[$conn];
$event['username']=$foundChater->getChatName();
break;
}
$topic->broadcast($event);
echo "onPublish {$conn->resourceId}\n";
}
我不明白为什么用排除方式发布不起作用。
在上面2个firefox中,对firefox说:我是吧。该消息不应该向他自己显示,但它确实如此。
我刚刚修好它。
我真是个傻瓜啊。我没有处理参数“array $exclude”
我还使用 $topic->broadcast($event) 强制向所有人广播。
现在我创建一个函数
/**
* check whitelist and blacklist
*
* @param array of sessionId $exclude -- blacklist
* @param array of sessionId $eligible -- whitelist
* @return array of \Ratchet\ConnectionInterface
*/
private function getPublishFinalList(array $exclude, array $eligible) {
//array of sessionId
$allSessionId = array();
$this->allChater->rewind();
while ($this->allChater->valid()) {
array_push($allSessionId, $this->allChater->current()->WAMP->sessionId);
$this->allChater->next();
}
//if whitelist exist, use whitelist to filter
if (count($eligible) > 0) {
$allSessionId = array_intersect($allSessionId, $eligible);
}
//then if blacklist exist, use blacklist to filter
if (count($exclude) > 0) {
$allSessionId = array_diff($allSessionId, $exclude);
}
//return array of connection
$result = array();
$this->allChater->rewind();
while ($this->allChater->valid()) {
$currentConn = $this->allChater->current();
if (in_array($currentConn->WAMP->sessionId, $allSessionId)) {
array_push($result, $currentConn);
}
$this->allChater->next();
}
return $result;
}
在onPublish中,我不再使用$topic->broadcast($event)。
$conn2PublishArray = $this->getPublishFinalList($exclude, $eligible);
foreach ($conn2PublishArray as $conn2Publish) {
$conn2Publish->event($topic, $new_event);
}
connection 类有一个方法 'even',可以直接向 '订阅者' 发送消息。
Ratchet.Wamp.WampConnection 事件方法