PHP如何开发微信公众号 PHP微信开发的完整流程

signature

timestamp

nonce

echostr

// 极简示例，实际开发会更复杂，用框架或库会更优雅
// index.php (假设这是你的服务器URL入口)

define("TOKEN", "你的公众号Token"); // 替换成你公众号后台设置的Token

if (isset($_GET['echostr'])) {
    // 首次配置接口认证
    $signature = $_GET["signature"];
    $timestamp = $_GET["timestamp"];
    $nonce = $_GET["nonce"];

    $tmpArr = array(TOKEN, $timestamp, $nonce);
    sort($tmpArr, SORT_STRING);
    $tmpStr = implode($tmpArr);
    $tmpStr = sha1($tmpStr);

    if ($tmpStr == $signature) {
        echo $_GET["echostr"];
        exit;
    } else {
        // 认证失败，可能Token不对或请求有问题
        error_log("WeChat signature check failed.");
        exit;
    }
} else {
    // 接收用户消息或事件推送
    $postStr = file_get_contents("php://input");
    if (!empty($postStr)) {
        $postObj = simplexml_load_string($postStr, 'SimpleXMLElement', LIBXML_NOCDATA);

        $fromUserName = $postObj->FromUserName; // 用户OpenID
        $toUserName = $postObj->ToUserName;     // 公众号原始ID
        $msgType = $postObj->MsgType;           // 消息类型

        $replyContent = "我收到了你的消息：";
        switch ($msgType) {
            case "text":
                $content = trim($postObj->Content);
                $replyContent .= $content;
                break;
            case "event":
                $event = $postObj->Event;
                if ($event == "subscribe") {
                    $replyContent = "欢迎关注！";
                } elseif ($event == "CLICK") {
                    $eventKey = $postObj->EventKey;
                    $replyContent = "你点击了菜单：".$eventKey;
                }
                break;
            // 更多消息类型处理...
            default:
                $replyContent = "我暂时无法处理这种类型的消息。";
                break;
        }

        // 构建回复XML
        $textTpl = "<xml>
                        <ToUserName><![CDATA[%s]]></ToUserName>
                        <FromUserName><![CDATA[%s]]></FromUserName>
                        <CreateTime>%s</CreateTime>
                        <MsgType><![CDATA[text]]></MsgType>
                        <Content><![CDATA[%s]]></Content>
                    </xml>";
        $resultStr = sprintf($textTpl, $fromUserName, $toUserName, time(), $replyContent);
        echo $resultStr;
    } else {
        echo ""; // 空白回复，表示不处理
        exit;
    }
}

// 假设你有一个缓存类或函数，例如用Redis
class AccessTokenManager {
    const CACHE_KEY = 'wechat_access_token';
    const EXPIRES_BUFFER = 60; // 提前60秒刷新

    public static function getAccessToken() {
        // 1. 从缓存中读取
        $cachedData = self::getFromCache(self::CACHE_KEY);

        // 2. 判断是否有效
        if ($cachedData && $cachedData['expires_at'] > time() + self::EXPIRES_BUFFER) {
            return $cachedData['token'];
        }

        // 3. 缓存失效，尝试获取锁
        // 这是一个简化的锁逻辑，实际需要更健壮的分布式锁
        if (self::acquireLock(self::CACHE_KEY . '_lock')) {
            try {
                // 双重检查：在获取锁后再次检查缓存，避免重复获取
                $cachedData = self::getFromCache(self::CACHE_KEY);
                if ($cachedData && $cachedData['expires_at'] > time() + self::EXPIRES_BUFFER) {
                    return $cachedData['token'];
                }

                // 4. 调用微信API获取新Token
                $url = "https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential&appid=YOUR_APPID&secret=YOUR_APPSECRET";
                $response = file_get_contents($url);
                $data = json_decode($response, true);

                if (isset($data['access_token'])) {
                    $token = $data['access_token'];
                    $expiresIn = $data['expires_in']; // 通常是7200秒
                    $expiresAt = time() + $expiresIn;

                    // 5. 存储到缓存
                    self::saveToCache(self::CACHE_KEY, ['token' => $token, 'expires_at' => $expiresAt]);
                    return $token;
                } else {
                    // 获取失败，记录错误日志
                    error_log("Failed to get WeChat Access Token: " . ($data['errmsg'] ?? 'Unknown error'));
                    throw new Exception("获取Access Token失败");
                }
            } finally {
                // 6. 释放锁
                self::releaseLock(self::CACHE_KEY . '_lock');
            }
        } else {
            // 未获取到锁，说明其他进程正在处理，等待并重试
            usleep(200000); // 等待200毫秒
            return self::getAccessToken(); // 递归调用，但实际生产不推荐无限递归，可加重试次数限制
        }
    }

    // 模拟缓存操作，实际用Redis等
    private static function getFromCache($key) {
        // return json_decode(file_get_contents("/tmp/$key.json"), true);
        // return Redis::get($key);
        return false; // 示例：始终返回false模拟缓存未命中
    }

    private static function saveToCache($key, $data) {
        // file_put_contents("/tmp/$key.json", json_encode($data));
        // Redis::set($key, json_encode($data), 'EX', $data['expires_at'] - time());
    }

    // 模拟分布式锁
    private static function acquireLock($key) {
        // return Redis::set($key, 1, 'NX', 'EX', 5); // 设置5秒过期，防止死锁
        return true; // 示例：始终成功获取锁
    }

    private static function releaseLock($key) {
        // Redis::del($key);
    }
}

// 调用示例
// try {
//     $accessToken = AccessTokenManager::getAccessToken();
//     echo "Current Access Token: " . $accessToken;
// } catch (Exception $e) {
//     echo "Error: " . $e->getMessage();
// }