阅读量:0
在PHP中使用STOMP协议时，可以通过消息头来对消息进行分类。以下是一个示例，展示了如何在接收到STOMP消息时根据消息头进行分类：
<?php // 创建一个用于连接STOMP服务器的socket $socket = new Socket("tcp://localhost:61613"); // 连接到STOMP服务器 $socket->connect(); // 订阅一个或多个STOMP频道 $socket->subscribe('/topic/my_category'); // 监听接收到的消息 while ($message = $socket->read()) { // 解码从STOMP服务器接收到的消息 $decoded_message = json_decode($message, true); // 获取消息头 $headers = $decoded_message['headers']; // 根据消息头中的'category'字段对消息进行分类 if (isset($headers['category']) && $headers['category'] == 'my_category') { // 处理属于'my_category'类别的消息 processMyCategoryMessage($decoded_message); } else { // 处理其他类别的消息 processOtherCategoryMessage($decoded_message); } } // 关闭与STOMP服务器的连接 $socket->close(); // 定义处理'my_category'类别消息的函数 function processMyCategoryMessage($message) { echo "Received my_category message: " . json_encode($message) . PHP_EOL; } // 定义处理其他类别消息的函数 function processOtherCategoryMessage($message) { echo "Received other category message: " . json_encode($message) . PHP_EOL; } ?> 在这个示例中，我们首先创建了一个socket连接到STOMP服务器，并订阅了/topic/my_category频道。然后，我们使用read()方法监听接收到的消息。对于每个接收到的消息，我们解码消息体并使用json_decode()函数将其转换为关联数组。接下来，我们从关联数组中提取消息头，并根据category字段的值对消息进行分类。如果category字段的值为my_category，则调用processMyCategoryMessage()函数处理该消息；否则，调用processOtherCategoryMessage()函数处理该消息。最后，我们关闭与STOMP服务器的连接。
