1、用的是tp5.1的框架,swoole分成一个客户端发送接收消息,一个服务器负责处理信息
服务端代码,服务器要先安装swoole拓展,用 php server.php 启动进程监听
推荐(免费):swoole
<?phpnamespace think;date_default_timezone_set('asia/shanghai');// 加载基础文件require_once __dir__ . '/thinkphp/base.php';// 支持事先使用静态方法设置request对象和config对象// 执行应用并响应//container::get('app')->run()->send();//require_once __dir__ . '/../../../thinkphp/helper.php';use think\cache\driver\redis;//use think\controller;use think\db;class swoole{ const errcode = array( 43004 => '需要接收者关注', 40037 => '无效模板', 40003 => '需要接收者关注', 43005 => '需要好友关系', 43019 => '需要将接收者从黑名单中移除', 44001 => '多媒体文件为空', 44002 => 'post 的数据包为空', 44003 => '图文消息内容为空', 44004 => '文本消息内容为空', 45001 => '多媒体文件大小超过限制', 45002 => '消息内容超过限制', 45003 => '标题字段超过限制', 45004 => '描述字段超过限制', 45005 => '链接字段超过限制', 45006 => '图片链接字段超过限制', 45007 => '语音播放时间超过限制', 45008 => '图文消息超过限制', 45009 => '接口调用超过限制', 45010 => '创建菜单个数超过限制', 45011 => 'api 调用太频繁,请稍候再试', ); private $serv; private $redis; private $conn = [ // 数据库类型 'type' => 'mysql', // 服务器地址 'hostname' => '', // 数据库名 'database' => '', // 用户名 'username' => '', // 密码 'password' => '', // 端口 'hostport' => '3306', // 连接dsn 'dsn' => '', // 数据库连接参数 'params' => [], // 数据库编码默认采用utf8 'charset' => 'utf8', // 数据库表前缀 'prefix' => 'shd_', // 数据库调试模式 'debug' => true, // 数据集返回类型 'resultset_type' => 'array', // 自动写入时间戳字段 'auto_timestamp' => false, // 时间字段取出后的默认时间格式 'datetime_format' => 'y-m-d h:i:s', // 是否需要进行sql性能分析 'sql_explain' => false, // builder类 'builder' => '', // query类 'query' => '\\think\\db\\query', // 是否需要断线重连 'break_reconnect' => false, // 断线标识字符串 'break_match_str' => [], ]; //初始化配置,监听端口 public function __construct() { //redis $this->redis = new redis(); $this->serv = new \swoole_server(0.0.0.0, 9501); $this->serv->set(array( 'worker_num' => 2, //一般设置为服务器cpu数的1-4倍 'daemonize' => 1, //以守护进程执行 'max_request' => 10000, 'dispatch_mode' => 2, 'task_worker_num' => 8, //task进程的数量 task_ipc_mode => 3, //使用消息队列通信,并设置为争抢模式 log_file => taskqueueu.log ,//日志 )); $this->serv->on('receive', array($this, 'onreceive')); // bind callback $this->serv->on('task', array($this, 'ontask')); $this->serv->on('finish', array($this, 'onfinish')); $this->serv->start(); } //接收客户端的请求并响应 public function onreceive(\swoole_server $serv, $fd, $from_id, $data) { echo get message from client {$fd}:{$data}\n; $serv->send($fd, '发送任务已建立,正在发送,请稍后查看发送记录'); // send a task to task worker. $serv->task($data);//投递任务 } public function ontask($serv, $task_id, $from_id, $data) { echo task {$task_id} task\n; $array = json_decode($data, true); $success = 0; $fail = 0; $log = ''; $access_token = $array['access_token']; $openid_list = $this->redis->smembers($array['appid'].'users');//从redis取出要批量发送的openid $fields = json_decode($array['data'],true); $send_data = array(); $start = time(); //模板消息 foreach ($openid_list as $openid) { $template = array( 'touser' => $openid, 'template_id' => $array['tem_id'], 'url' => $array['url'], 'topcolor' => #000000, 'data' => $send_data, ); $url = https://api.weixin.qq.com/cgi-bin/message/template/send?access_token= . $access_token; $res = $this->send_post($url, $template); $res_arr = json_decode($res, true); if ($res_arr['errcode'] == 0){ ++ $success; }else{ ++ $fail; $log = self::errcode[$res_arr['errcode']]; } } $result = array('success'=>$success,'fail'=>$fail,'tem_id'=>$array['tem_id'],'uid'=>$array['uid'],'data'=>$array['data'],'url'=>$array['url'],'log'=>$log,'start'=>$start); return json_encode($result); } //任务执行完自动回调结束方法 public function onfinish($serv, $task_id, $data) { $array = json_decode($data,true); $fields = json_decode($array['data'],true); //获取当前模板 $list = db::connect($this->conn)->name('wechat_template')->where('template_id',$array['tem_id'])->where('uid',$array['uid'])->find(); $new_field = $list['field']; $insert['template_id'] = $array['tem_id']; $insert['success'] = $array['success']; $insert['fail'] = $array['fail']; $insert['url'] = $array['url']; $insert['log'] = $array['log']; $insert['create_time'] = date('y-m-d h:i:s',$array['start']); $insert['finish_time'] = date('y-m-d h:i:s'); db::connect($this->conn)->name('wechat_template_log')->insert($insert); echo task{$data} {$task_id} finish\n; } function send_post($url, $post_data) { $postdata=json_encode($post_data,json_unescaped_unicode); $options = array( 'http' => array( 'method' => 'post', 'header' => 'content-type:application/x-www-form-urlencoded', 'content' => $postdata,// 'protocol_version' => 1.1,// 'header' => [// 'connection: close',// ], 'timeout' => 2 // 超时时间(单位:s) ) ); $context = stream_context_create($options); $result = file_get_contents($url, false, $context); return $result; }}$server = new swoole();
2、客户端请求,可以通过api访问
function send_tem_to(){ $type = input('type'); // 0 按人头算 1 按标签算 2 全部粉丝 $target = input('target/s'); $field = input('fields/s'); $tem_id = input('tem_id');//模板id,字符串 $url = input('url',''); $client = new \swoole_client(swoole_sock_tcp);//创建同步tcp if (!$client->connect('127.0.0.1', 9501, 0.5))//链接 { exit(connect failed. error: {$client->errcode}\n); } $client->send(json_encode(array('appid'=>$this->appid,'uid'=>$this->uid,'tem_id'=>$tem_id,'data'=>$field))); //发送请求 $rec = $client->recv();//接收返回数据 $client->close();//关闭链接 }
以上就是介绍swoole异步群发模板消息的详细内容。