队列使用手册 -

步骤一：准备工作

下载文件CreateQueueAndSendMessage.php。
打开CreateQueueAndSendMessage.php文件，在文件的最下方配置AccessKeyId、AccessKeySecret和Endpoint。
- AccessKeyId、AccessKeySecret
  - 访问阿里云API的密钥对。
  - 如果使用阿里云账号访问，请登录AccessKey管理页面创建、查看。
  - 如果使用RAM用户访问，请登录阿里云访问控制控制台查看。
- Endpoint
  - 访问消息服务MNS的接入地址，请登录MNS控制台查看。具体操作，请参见获取接入点。
  - 不同地域的接入地址不同。

CreateQueueAndSendMessage的代码最上方有一些设置，使用SDK的时候进行同样的设置。

//require SDK里自带的一个autoload文件。
require __DIR__ . '/vendor/autoload.php';

// 代码里需要用的一些php class。
use AliyunMNS\Client;
use AliyunMNS\Requests\SendMessageRequest;
use AliyunMNS\Requests\CreateQueueRequest;
use AliyunMNS\Exception\MnsException;

步骤二：创建队列

如果之前未创建队列，那么首先需要创建队列。默认创建的队列名称是CreateQueueAndSendMessageExample，也可以修改代码指定队列名称。

// 1.首先初始化一个client。
$this->client = new Client($this->endPoint, $this->accessId, $this->accessKey);

// 2.生成一个CreateQueueRequest对象。CreateQueueRequest还可以接受一个QueueAttributes参数，用来初始化生成的queue的属性。
// 对于queue的属性，请参见Queue。
$request = new CreateQueueRequest($queueName);
try
{
        $res = $this->client->createQueue($request);
        // 3.创建队列成功。
        echo "QueueCreated! \n";
}
catch (MnsException $e)
{
        // 4.可能因为网络错误，或者Queue已经存在等原因导致CreateQueue失败，这里CatchException并做对应的处理。
         echo "CreateQueueFailed: " . $e;
         return;
}

步骤三：发送消息

创建队列后，发送消息到队列。

// 1.首先获取Queue的实例。
// PHP SDK默认会对发送的消息做Base64 Encode，对接收到的消息做Base64 Decode。
// 如果不希望SDK做这样的Base64操作，可以在getQueueRef的时候，传入参数$base64=FALSE。即$queue = $this->client->getQueueRef($queueName, FALSE);
$queue = $this->client->getQueueRef($queueName);

$messageBody = "test";
// 2.生成一个SendMessageRequest对象。
// SendMessageRequest对象本身也包含了DelaySeconds和Priority属性可以设置。
// 对于Message的属性，请参见QueueMessage。
$bodyMD5 = md5(base64_encode($messageBody));
$request = new SendMessageRequest($messageBody);
try
{
        $res = $queue->sendMessage($request)
        // 3.消息发送成功。
        echo "MessageSent! \n";
}
catch (MnsException $e)
{
        // 4.可能因为网络错误，或MessageBody过大等原因造成发送消息失败，这里CatchException并做对应的处理。
        echo "SendMessage Failed: " . $e;
        return;
}

步骤四：接收和删除消息

队列里已经有了一条消息，现在可以尝试接收消息。

NextVisibleTime是消息服务MNS的消息的一个重要属性。更多信息，请参见QueueMessage。

$receiptHandle = NULL;
try
{
        // 1.直接调用receiveMessage函数。
        // receiveMessage函数接受waitSeconds参数，无特殊情况建议设置为30。
        // waitSeconds非0表示这次receiveMessage是一次http long polling，如果queue内没有message，那么这次request会在server端等到queue内有消息才返回。最长等待时间为waitSeconds的值，最大为30。
        $res = $queue->receiveMessage(30);
        echo "ReceiveMessage Succeed! \n";
        if (strtoupper($bodyMD5) == $res->getMessageBodyMD5())
        {
             echo "You got the message sent by yourself! \n";
        }
        // 2.获取ReceiptHandle，这是一个有时效性的Handle，可以用来设置Message的各种属性和删除Message。更多信息，请参见QueueMessage。
        $receiptHandle = $res->getReceiptHandle();
}
catch (MnsException $e)
{
        // 3.和CreateQueue和SendMessage一样，ReceiveMessage也有可能出错，所以加上CatchException并做对应的处理。
        echo "ReceiveMessage Failed: " . $e;
        return;
}

// 这里是您处理消息的逻辑。Sample里就直接略过这一步。
// 如果这里发生了程序崩溃或卡住等异常情况，对应的Message会在VisibilityTimeout之后重新可见，从而可以被其他进程处理，避免消息丢失。

// 4.消息已经处理完成，从队列里删除这条消息。
try
{
        // 5.直接调用deleteMessage。
        $res = $queue->deleteMessage($receiptHandle);
        echo "DeleteMessage Succeed! \n";
}
catch (MnsException $e)
{
        // 6.这里CatchException并做异常处理。
        // 如果是receiptHandle已经过期，那么ErrorCode是MessageNotExist，表示通过这个receiptHandle已经找不到对应的消息。
        // 为了保证receiptHandle不过期，VisibilityTimeout的设置需要保证足够消息处理完成。并且在消息处理过程中，也可以调用changeMessageVisibility这个函数来延长消息的VisibilityTimeout时间。
        echo "DeleteMessage Failed: " . $e;
        return;
}

步骤五：删除队列

Sample里最后会删除这个测试队列。

try {
        $this->client->deleteQueue($queueName);
        echo "DeleteQueue Succeed! \n";
} catch (MnsException $e) {
        echo "DeleteQueue Failed: " . $e;
        return;
}