本文档介绍了如何使用 Amazon SNS 服务通过 PHP SDK 发送 SMS 消息，并详细阐述了如何通过 CloudWatch API 获取 SMS 消息的投递状态，以便开发者能够监控消息发送结果并及时处理异常。
Amazon Simple Notification Service (SNS) 是一种快速、灵活、完全托管的推送消息服务。您可以使用 SNS 发送消息到移动设备、电子邮件地址、其他 AWS 服务等。本教程将重点介绍如何使用 PHP SDK 发送 SMS 消息，并介绍如何获取消息的投递状态。
发送 SMS 消息
首先，确保您已经安装了 AWS PHP SDK。您可以使用 Composer 进行安装：
composer require aws/aws-sdk-php
接下来，使用以下代码发送 SMS 消息：
<?php
require 'vendor/autoload.php';
use Aws\Sns\SnsClient;
$sdk = new SnsClient([
'region' => 'eu-west-1', // 替换为您的 AWS 区域
'version' => 'latest',
'credentials' => [
'key' => 'YOUR_AWS_ACCESS_KEY_ID', // 替换为您的 AWS 访问密钥 ID
'secret' => 'YOUR_AWS_SECRET_ACCESS_KEY', // 替换为您的 AWS 秘密访问密钥
]
]);
try {
$result = $sdk->publish([
'Message' => 'This is a test message.',
'PhoneNumber' => '+1234567890', // 替换为目标手机号码，包含国家码
'MessageAttributes' => [
'AWS.SNS.SMS.SenderID' => [
'DataType' => 'String',
'StringValue' => 'MySenderID' // 替换为您希望显示的发送者 ID (可选)
]
]
]);
print_r($result);
} catch (Aws\Exception\AwsException $e) {
// 输出错误信息
echo 'Error: ' . $e->getMessage();
}
?>代码解释：
- require 'vendor/autoload.php';： 引入 Composer 自动加载器，加载 AWS PHP SDK。
- new Aws\Sns\SnsClient([...])： 创建 SNS 客户端实例，需要配置 AWS 区域、版本和凭证。
- $sdk->publish([...])： 调用 publish 方法发送 SMS 消息。
- Message： 消息内容。
- PhoneNumber： 目标手机号码，必须包含国家码。
- MessageAttributes： 消息属性，可以设置发送者 ID 等。
- try...catch： 捕获可能发生的 AWS 异常，并输出错误信息。
注意事项：
- 请确保您已配置正确的 AWS 区域和凭证。
- 目标手机号码必须包含国家码。
- 发送者 ID 是可选的，但某些国家/地区可能要求必须设置。
- 您需要在 AWS 管理控制台中为您的 AWS 账户启用 SMS 发送功能。
获取投递状态
Amazon SNS 本身不直接提供回调 URL 用于接收投递状态。目前，获取 SMS 消息投递状态的主要方法是使用 Amazon CloudWatch Logs。SNS 会将 SMS 消息的投递日志发送到 CloudWatch Logs，您可以通过 CloudWatch API 查询这些日志。
步骤：
配置 SNS 将 SMS 消息日志发送到 CloudWatch Logs。 您需要在 AWS 管理控制台中配置 SNS，使其将 SMS 消息的日志发送到指定的 CloudWatch Logs 日志组。
使用 CloudWatch API 查询日志。 您可以使用 AWS PHP SDK 中的 CloudWatch Logs 客户端查询日志。
以下是一个使用 CloudWatch Logs API 获取日志事件的示例代码：
<?php
require 'vendor/autoload.php';
use Aws\CloudWatchLogs\CloudWatchLogsClient;
$client = new CloudWatchLogsClient([
'region' => 'eu-west-1', // 替换为您的 AWS 区域
'version' => 'latest',
'credentials' => [
'key' => 'YOUR_AWS_ACCESS_KEY_ID', // 替换为您的 AWS 访问密钥 ID
'secret' => 'YOUR_AWS_SECRET_ACCESS_KEY', // 替换为您的 AWS 秘密访问密钥
]
]);
$logGroupName = '/aws/sns/sms'; // 替换为您的 CloudWatch Logs 日志组名称
$logStreamName = 'YourLogStreamName'; // 可选，如果知道具体的日志流名称，可以指定
try {
$result = $client->getLogEvents([
'logGroupName' => $logGroupName,
//'logStreamName' => $logStreamName, // 可选
'startTime' => strtotime('-1 hour') * 1000, // 查询过去一小时内的日志
'endTime' => time() * 1000,
'limit' => 100, // 限制返回的日志事件数量
'startFromHead' => true, // 从日志流的开头开始读取
]);
foreach ($result['events'] as $event) {
echo $event['message'] . "\n";
// 在这里解析日志消息，提取投递状态信息
}
} catch (Aws\Exception\AwsException $e) {
echo 'Error: ' . $e->getMessage();
}
?>代码解释：
- new Aws\CloudWatchLogs\CloudWatchLogsClient([...])： 创建 CloudWatch Logs 客户端实例，需要配置 AWS 区域、版本和凭证。
- $client->getLogEvents([...])： 调用 getLogEvents 方法查询日志事件。
- logGroupName： CloudWatch Logs 日志组名称。
- logStreamName： 可选，如果知道具体的日志流名称，可以指定。
- startTime： 查询的起始时间，Unix 时间戳（毫秒）。
- endTime： 查询的结束时间，Unix 时间戳（毫秒）。
- limit： 限制返回的日志事件数量。
- startFromHead： 从日志流的开头开始读取。
- foreach ($result['events'] as $event)： 遍历返回的日志事件，并解析日志消息，提取投递状态信息。
注意事项：
- 请确保您已配置正确的 AWS 区域和凭证。
- 您需要根据实际情况修改 logGroupName 和 logStreamName。
- 日志消息的格式可能因 SNS 配置而异，您需要根据实际情况解析日志消息。
- 可以使用更复杂的过滤条件，例如使用 filterPattern 参数，来更精确地查询日志。
总结：
虽然 Amazon SNS 不直接提供回调 URL 用于接收投递状态，但您可以使用 CloudWatch Logs API 查询 SMS 消息的投递日志，从而获取投递状态信息。 这种方法需要您配置 SNS 将日志发送到 CloudWatch Logs，并编写代码来查询和解析日志。 通过这种方式，您可以有效地监控 SMS 消息的发送结果并及时处理异常。
