PHP 范例 Messaging operations

PHP Manual
范例
Messaging operations

Messaging operations

All messaging operations are performed through calls to methods on the connection object. To add a message to a queue the "send" method is used, to obtain a message from a queue the "receive" method is used. Other methods provide publish and subscribe functionality and control of transaction boundaries.

Example #1 Adding a message to a queue and receiving a response

 <?php
$msg = new SAMMessage('This is a simple text message');
$msg->header->SAM_REPLY_TO = 'queue://receive/test';
$correlid = $conn->send('queue://send/test', $msg);

if (!$correlid) {
  // The Send failed!
  echo "Send failed ($conn->errno) $conn->error";
} else {
  $resp = $conn->receive('queue://receive/test', array(SAM_CORRELID => $correlid));
}
?>

php 其它服务 simple asynchronous messaging php gnupg 函数 returns the currently active protocol for all operations php stream context options callback when executing killcursor operations php maxdb 函数 performs debugging operations php zookeeper 函数 calls callbacks for pending operations php harupage end current path object without filling and painting operations php mongodb driver bulkwrite count number of write operations in the bulk php mongodb driver manager execute one or more write operations php mongodb driver server execute one or more write operations on this server php mysql xdevapi crudoperationskippable number of operations to skip php mysqli performs debugging operations php phar used to determine whether phar write operations are being buffered or are flushing directly to disk php phar start buffering phar write operations do not modify the phar object on disk php 范例 messaging operations php sam 函数 establishes a connection to a messaging server php sam 函数 creates a new connection to a messaging server php sam 函数 disconnects from a messaging server php sam 函数 queries whether a connection is established to a messaging server php swoole mmap map a file into memory and return the stream resource which can be used by php stream operations.php tidy execute configured cleanup and repair operations on parsed markup