Swoole协程已经发展到了4.0现在已经支持所有PHP函数。可以在生产环境直接使用。Swoole协程是通过减少IO阻塞来提速的一个项技术，统计协程调度减少IO阻塞，让你的程序飞起。微信公众号管理，小程序管理，这类程序对于IO操作相当频繁。所以使用Swoole协程能极大的提高程序负责，提升程序运行速度。

下面让我们用几步来快速创建一个微信管理系统。

1、安装EasySwoole

EasySwoole是一个特别不错的项目,Swoole初学者直接的去阅读文档理解起来很困难，但是通过EasySwoole去学习去使用，然后加深对Swoole的认识，是快速理解协程技术的一个很不错的方法。EasySwoole提供了很多教学视频，案例，这些对于初学者很有帮助。

# 安装框架composer require easyswoole/easyswoolephp vendor/bin/easyswoole install# 启动框架php easyswoole start

2、安装微信SDK

EasySwoole有专门的微信SDK直接安装即可

# 安装Sdkcomposer require easyswoole/wechat#微信SDKdemo地址：

3、注册微信服务

注册服务对于新手来说理解起来有些别扭。其实对于EasySwoole的方式也很好理解，他是内存中的代码。什么是内存中的代码呢？最火的Laravel程序代码是写在文件存储的，程序每次会执行程序中的代码，EasySwoole是将代码存储在内存中的，运行后代码会一直在内存中贮存。Laravel当修改文件中的代码时你的程序将自动按照新代码进行执行。EasySwoole改变文件中的代码正在执行的程序不会进行改变，需要重新启动才能获得新的代码。对比按照的服务器大家也能直白的发现，Laravel的内存消耗比较小，CPU跳动比较大。EasySwoole则是CPU基本不怎么动，但是运行起来内存消耗会相对大一些。

EasySwoole和Laravel的差异就如同图中的色块

下面是EasySwooleEvent.php 中的服务注册：

#拿到配置环境的公众号列#注册服务时不能使用数据库连接#从数据库获取数据的，#这时数据库连接服务刚刚注册，并不能使用$weChatList = Config::getInstance()->getConf('GONG_ZHONG_HAO');if(count($weChatList)>0){  #对每一个公众号进行服务注册  foreach ($weChatList as $key => $value) {    $temp = WeChatManager::getInstance()->weChat($value['appId']);    #WeChatManager 是一个对象管理器，是为了快速获取公众号号对象的。    //创建服务    $weChat = $temp->officialAccount()->server();    Logger::getInstance()->console('debug', false);    #事件监听    // 注册收到文本消息事件    $weChat->onMessage()      ->set(RequestConst::MSG_TYPE_TEXT, function (RequestMsg $requestMsg) {      #TextMessageHandler 监控类      return TextMessageHandler::handle($requestMsg);    });    //与常规消息不同，事件类的则通过 onEvent 方法来进行注册处理机制，这里是一个用户关注事件    $weChat->onEvent()      ->onSubscribe(function (RequestMsg $requestMsg){      #EventMessageHandler 监控类      return EventMessageHandler::subscribe($requestMsg);    });    //也可以注册默认 和自定义事件处理    $weChat->onEvent()      ->set(RequestConst::DEFAULT_ON_EVENT,function (RequestMsg $requestMsg){      #EventMessageHandler 监控类      return EventMessageHandler::handle($requestMsg);    });  }}

4、新建微信管理控件

微信管理控件其实是指的 WeChatManager类。当然如果你仅仅需要管理一个公众号的话其实不用这个类的。但是既然你是程序员，就不要低估自己的实力。搞定多公众号配置这个对你来说还是很简单的。

下面是类中的主要代码：

class WeChatManager{    // 单例化 进程内共享    use Singleton;    /** @var array 存储全部WeChat对象 */    private $weChatList = [];    //实例自动注册    private function register(string $appId): WeChat    {        $weChatList = Config::getInstance()->getConf('GONG_ZHONG_HAO');        $configArray = false;        foreach ($weChatList as $key => $value) {            if($appId == $value['appId']){                $configArray = [                    'appId'     => $value['appId'],                    'appSecret' => $value['appSecret'],                    'token'     => $value['token'],                    'AesKey'    => $value['AesKey'],                ];            }        }        if(!$configArray){            throw new RuntimeException('公众号不存在.');        }        $weChatConfig = new \EasySwoole\WeChat\Config();        $weChatConfig->setTempDir(Config::getInstance()          ->getConf('TEMP_DIR'));        $weChatConfig->officialAccount($configArray);        $weChat = new WeChat($weChatConfig);        $this->weChatList[$appId] = $weChat;        return $weChat;    }    //实例获取    public function weChat(string $appId): WeChat    {        if (isset($this->weChatList[$appId])) {            return $this->weChatList[$appId];        }else{            return $this->register($appId);        }    }}

5、创建微信交互接口

服务注册完，管理控件完成，只能说系统可以使用SDK处理微信消息了。但是大家都知道，我们需要两个接口和微信进行通讯。

#创建路由$routeCollector->get('/token/{appId}', '/WeChat/Index/token');$routeCollector->post('/token/{appId}', '/WeChat/Index/message');

路由中有两个接口GET和POST。一个是消息验证，一个是数据交互。

数据验证：

public function token(){  // 将微信发来的 params 参数创建为 AccessCheck Bean对象  $accessCheckBean = new AccessCheck($this->request()->getRequestParam());  $weChat = WeChatManager::getInstance()    ->weChat($this->request()->getRequestParam('appId'));  $verify = $weChat->officialAccount()    ->server()    ->accessCheck($accessCheckBean);  // 如果验证为真(来自于微信服务器的请求)  if ($verify) {    // 按照微信约定 响应 Code 200 并在 Body 输出计算出的值    $this->response()->withStatus(Status::CODE_OK);    $this->response()->write($accessCheckBean->getEchostr());  }  // 结束此响应  $this->response()->end();}

数据交互：

// 此 API 主要服务 微信公众平台的 消息事件public function message(){  // 将微信发来的 params 参数创建为 AccessCheck Bean对象  $accessCheckBean = new AccessCheck($this->request()->getRequestParam());  $weChat = WeChatManager::getInstance()    ->weChat($this->request()->getRequestParam('appId'));  /** @var string 微信发送的Body体 $rawContent */  $rawContent = $this->request()    ->getBody();  // 将请求转发给名为 'default' WeChat接管 会返回 XML string 或者 null  try {    $XML = $weChat->officialAccount()      ->server()      ->parserRequest($rawContent);  } catch (Throwable $throwable) {    // 这里我建议开发者 catch 住异常 无论如何给用户响应友好的提示 防止出现公众号异常的问题    // TODO: 这里实现一个异常记录 和发送服务器异常通知给开发者的代码    Logger::getInstance()      ->log('DEBUG-F',Logger::LOG_LEVEL_INFO,'DEBUG');  }  $this->response()->withStatus(Status::CODE_OK);  $this->response()->write($XML ?? 'success');  }

6、业务逻辑处理类（监控类）

token函数用于验证微信第三方服务器真实性，主要交互还在message函数中。这时一个完整的微信三方管理循环已经搭建完成。信息从微信服务器，通过请求到message函数中。通过已经注册的服务，会交还给监控类。大家只要去编辑监控类进行数据处理和回调就可以咯。

下面先添加关注事件：EventMessageHandler::subscribe($requestMsg);

public static function subscribe(RequestMsg $requestMsg){  $openid = $requestMsg->getFromUserName();  Logger::getInstance()->console('---subscribe---', false);  //关注  $reply = new Text();  $reply->setContent(self::$return);  $user = WechatModel::create()    ->where('openid',$openid)    ->get();  if(!$user){    WechatModel::create()->data([      'openid'=>$openid,      'keyword'=>uniqid(),      'update_time'=>time(),      'create_time'=>time()    ], false)->save();  }  return $reply;}

7、对接测试

将公众号第三方入口改成自己的服务器地址：{appId}然后关注一下看看自己的数据表吧