swoole php input,介绍swoole异步群发模板消息
1、用的是TP5.1的框架,swoole分成一个客户端发送接收消息,一个服务器负责处理信息
服务端代码,服务器要先安装swoole拓展,用 php server.php 启动进程监听
推荐(免费):swoole<?php
namespace 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 php input,介绍swoole异步群发模板消息相关推荐
- 如何快速实现公众号群发模板消息
自己开发群发模板消息的功能太复杂了,首先要开发用户系统获取用户openId,然后要开发多线程群发消息系统,业务逻辑复杂.开发难度大.运行不稳定.维护成本高,这些都是让大家对模板消息望而却步的主要原因. ...
- 公众平台模板消息所在行业_如何使用微信公众号第三方平台群发模板消息助手?...
对于微信公众号群发模板消息助手的实现,公众号后台提供了接口编程实现,微号帮平台提供了模板消息群发功能实现,均可以让微信公众号群发模板消息,模板消息即按固定格式的文本模块消息,没有图文形式,纯固定格式的 ...
- Swoole结合Thinkphp发送10万+微信模板消息
使用Thinkphp5.0框架 服务端: <?php namespace app\Console;use think\console\Command; use think\console\Inp ...
- swoole系列(一)- swoole入门与介绍
目录 1. swoole的概念介绍 1.1 介绍Swoole - 概念 - 网络通信 1.2 介绍Swoole-与workerman的碰撞 1.3.介绍Swoole-应用 1.4.介绍Swoole-衍 ...
- 微信小程序模板消息群发、无限制推送相关讲解
模版消息推送是微信小程序采用的通知形式,用户本人在小程序页面有交互行为后,可触发下发通知,通过微信聊天列表中的服务通知可快捷进入查看消息.此外,点击查看详情还能跳转到下发消息的小程序的指定页面.但是为 ...
- 【转】微信小程序模板消息无限制群发
模版消息推送是微信小程序采用的通知形式, 用户本人在小程序页面有交互行为后,可触发下发通知 ,通过微信聊天列表中的服务通知可快捷进入查看消息.此外,点击查看详情还能跳转到下发消息的小程序的指定页面.但 ...
- 微信小程序模板消息无限制群发
模版消息推送是微信小程序采用的通知形式, 用户本人在小程序页面有交互行为后,可触发下发通知 ,通过微信聊天列表中的服务通知可快捷进入查看消息.此外,点击查看详情还能跳转到下发消息的小程序的指定页面.但 ...
- 微信小程序模板消息还能群发?无限制推送?
模版消息推送是微信小程序采用的通知形式,用户本人在小程序页面有交互行为后,可触发下发通知,通过微信聊天列表中的服务通知可快捷进入查看消息.此外,点击查看详情还能跳转到下发消息的小程序的指定页面.但是为 ...
- 公众平台模板消息所在行业_第三方工具微信公众号模板消息群发如何操作?
当下,公众平台模板消息功能仅支持添加模板,修改所在行业,如果想要群发模板消息,可以自己根据公众平台的接口编程实现,也可通过微号帮平台的模板消息群发功能实现,均可以让微信公众号群发模板消息,模板消息即按 ...
最新文章
- 人类高质量AI训练方式:精细化数据集管理颠覆唯SOTA论
- android studio miui8,MIUI8上在Android Studio运行出错集及其解决方案
- python输出数据到excel-如何使用python将大量数据导出到Excel中的小技巧之一
- shiro+springboot分析思路
- 如何使用yum来下载RPM包而不进行安装
- hdfs如何查找指定目录是否文件_hadoop实战教程-HDFS文件系统如何查看文件对应的block...
- windows安装HTK3.4.1
- python人脸识别教程_50行Python代码+OpenCV实现人脸识别!史上最详细的教程!
- C语言和设计模式(状态模式)
- python3 tkinter 桌面软件教程
- 【图卷积网络】Graph Convolutional Network
- 【Maven】阿里镜像仓库地址
- c++ 让程序玩贪吃蛇游戏
- js中易错难点集合(1)
- oracle start with connect by order siblings by用法
- jq动态改变路径_在react中使用jQuery动态更改图片路径遇到的问题
- iPhone 14 Pro/Max出大问题:从旧款机型传输数据后卡死黑屏无法开机!
- 2021年东方市铁路中学高考成绩查询,2021东方市中考分数线预测
- SAP 解析销售订单的状态
- 抗疫先锋 | 航天科工 万物互联 万网融合