php小程序订阅消息发送功能对接实践

php小程序订阅消息发送功能对接实践

在开发小程序的过程中，订阅消息功能是与用户保持互动的重要方式之一。本文将详细介绍如何使用 PHP 语言对接小程序的订阅消息发送功能，帮助开发者快速理解和实现这一功能。

一、功能概述

小程序的订阅消息功能允许开发者在用户主动订阅后，向用户发送模板消息。这可以用于通知用户重要的信息，如订单状态、活动提醒等。订阅消息的发送需要满足以下条件：

1. 用户必须主动订阅消息模板。
2. 开发者需要正确配置小程序的 appid 和 secret。
3. 发送消息时需要使用提供的 API 接口。

二、开发环境与工具

• 语言：PHP
• 框架：无特定框架要求，但建议使用面向对象的方式封装代码。
• 依赖：cURL 扩展用于 HTTP 请求。

三、实现步骤

1. 获取 Access Token

小程序的 API 接口需要使用 access_token 进行身份验证。access_token 是通过小程序的 appid 和 secret 获取的，有效期为 2 小时。

php复制

class WxHelper
{
    public static function getAccessToken($appId, $appSecret)
    {
        $url = ";appid={$appId}&secret={$appSecret}";
        $respe = self::curl($url);
        $respeJson = json_decode($respe, true);
        if (isset($respeJson['errcode'])) {
            throw new Exception("获取 Access Token 失败：{$respeJson['errmsg']}");
        }
        return $respeJson['access_token'];
    }

    public static function curl($url, $postData = null)
    {
        $ch = curl_init();
        curl_setopt($ch, CURLOPT_URL, $url);
        curl_setopt($ch, CURLOPT_RETURTRASFER, 1);
        if ($postData !== null) {
            curl_setopt($ch, CURLOPT_POST, 1);
            curl_setopt($ch, CURLOPT_POSTFIELDS, $postData);
        }
        $respe = curl_exec($ch);
        curl_close($ch);
        return $respe;
    }
}

2. 封装订阅消息发送功能

订阅消息的发送需要调用的 API 接口。我们将这一功能封装到 WxService 类中。

php复制

class WxService
{
    private $appId;
    private $appSecret;

    public function setAppId($appId)
    {
        $this->appId = $appId;
    }

    public function setAppSecret($appSecret)
    {
        $this->appSecret = $appSecret;
    }

    public function getAccessToken()
    {
        return WxHelper::getAccessToken($this->appId, $this->appSecret);
    }

    /**
     * 发送订阅消息
     * @param array $message
     * @throws BusinessException
     */
    public function sendSubscribeMessage(array $message)
    {
        WxHelper::sendSubscribeMessage($this->getAccessToken(), $message);
    }
}

. 实现订阅消息发送逻辑

在 WxHelper 类中，我们实现具体的发送逻辑。

php复制

class WxHelper
{
    public static function sendSubscribeMessage(string $access_token, array $message)
    {
        // 接口地址
        $api = "={$access_token}";

        // 请求接口
        $respe = self::curl($api, json_encode($message, JSO_UESCAPED_UICODE));

        // 检查返回内容
        if (!$respe) {
            throw new BusinessException("订阅消息服务接口未响应内容");
        }

        // 检查响应内容
        $respeJson = json_decode($respe, true);
        if (isset($respeJson['errcode']) && $respeJson['errcode'] !== 0) {
            $errStr = "错误码:{$respeJson['errcode']},错误信息:{$respeJson['errmsg']}";
            throw new BusinessException("订阅消息服务异常, $errStr");
        }
    }
}

4. 调用发送功能

在业务逻辑中，我们调用封装好的发送功能。例如，发送一条考试报名提醒消息：

php复制

$data = [
    'template_id' => 'PnwM91L28BIb5_R6dkt1MdBeIcdSVo7ZVDxZiwQjE',
    'touser' => 'oPgSR62Qp7G1H8fXdBMb9mCZaxuo',
    'data' => [
        'thing1' => ['value' => '自学考试'],
        'time' => ['value' => '2025年1月10日'],
        'thing4' => ['value' => '报考今日开始，请记得及时报名'],
    ],
];

$s = new WxService();
$s->setAppId('YOUR_APP_ID');
$s->setAppSecret('YOUR_APP_SECRET');
$s->sendSubscribeMessage($data);

四、常见问题及解决方法

1. 获取 Access Token 失败：
   • 检查 appid 和 secret 是否正确。
   • 确保网络请求正常，无防火墙或代理限制。
2. 发送消息失败：
   • 检查用户是否已订阅模板消息。
   • 确保模板消息的格式符合要求。
   • 检查返回的错误码和错误信息，根据提示解决问题。
3. 接口响应超时：
   • 增加 cURL 的超时时间。
   • 检查服务器状态是否正常。