PHP のリロードとカールの並行方法を使用して、Xiaomi プッシュ SDK をエレガントにカプセル化します
- 高洛峰オリジナル
- 2016-10-15 16:27:241652ブラウズ
少し前に、以前は他の人が担当していた Xiaomi Push のコードをいくつか移行しました。コードを読んだ後、次の 2 つの点を発見しました:
URL とパラメーターの送信を除いて、すべてのインターフェイスの実装は基本的に同じです
Android デバイスと iOS デバイスはそれぞれ 1 回プッシュする必要があります
PHP のリロードの概念について学んだところですこの間、[型とメソッドの動的作成は、同じメソッド名を持つ Java やその他のパラメーターの概念とは異なります。具体的な概念は RTFM であり得る] ので、
上記の最初の点について。 : PHP の再利用の概念を使用することは可能ですか? マジック メソッド __call() を使用して、インターフェイス呼び出しの URL パラメーターとリクエスト パラメーターを動的に変更し、Xiaomi によってプッシュされたさまざまなインターフェイスへの呼び出しを実装します。呼び出しロジックは __call メソッドに実装されていますが、Xiaomi を別のインターフェイスにプッシュするための外部呼び出しメソッドが提供されているため、コードが大幅に簡素化されます
上記の 2 番目の点については、curl の並列モードを使用して Android と iOS にプッシュできますか?これにより、理論的には、あるタイプのデバイスへのプッシュが完了するのを待ってから別のタイプのデバイスにプッシュする必要がなくなるため、理論的にはプッシュ呼び出しの時間を短縮できます
次に、書き込みを開始しますコード。まず、mipush エンティティを構築します。エンティティのメンバー属性には、実行環境、いくつかの初期化された構成パラメーター、実装された Xiaomi インターフェイスの情報 (インターフェイス URI とパラメーターなど) が含まれます。
/**
* 运行环境 develop：开发环境 product：生产环境
* @var string
*/
private $_environment = 'develop';
/**
* 设备系统类型 android ios
* @var string
*/
private $_osType = '';
/**
* 小米推送域名
* @var string
*/
private $_host = '';
/**
* 请求头
* @var string
*/
private $_headers = '';
/**
* 接口url
* @var string
*/
private $_url = '';
/**
* 调用的接口方法名称
* @var array
*/
private $_function = [];
/**
* 请求参数
* @var array
*/
private $_data = [];
/**
* 小米推送设置
* @var array
*/
private $_options = [
'title' => '消息通知自定义title',
'restricted_package_name' => '',
'pass_through' => 0, // 0 通知栏消息 1 透传
'notify_type' => -1, // -1:默认所有,1:使用默认提示音提示,2:使用默认震动提示,4:使用默认led灯光提示
'time_to_send' => 0, // 定时推送 单位毫秒 默认0
];
/**
* 运行环境配置
* @var array
*/
private static $_environmentConfig = [
'domain' => [
'product' => 'https://api.xmpush.xiaomi.com/',
'develop' => 'https://sandbox.xmpush.xiaomi.com/'
],
];
/**
* 小米推送接口信息定义
*
* url/请求参数
* @var array
*/
private $_functionDefine = [
'regid' => [
'uri' => 'v3/message/regid',
'arguments' => [
'registration_id' => [
'type' => 'array',
'must' => 'y'
],
'description' => [
'type' => 'string',
'must' => 'y'
],
'params' => [//自定义参数
'type' => 'array',
'must' => 'n'
],
]
],
'userAccount' => [
'uri' => 'v2/message/user_account',
'arguments' => [
'user_account' => [
'type' => 'array',
'must' => 'y'
],
'description' => [
'type' => 'string',
'must' => 'y'
],
'params' => [//自定义参数
'type' => 'array',
'must' => 'n'
],
]
],
'alias' => [
'uri' => 'v3/message/alias',
'arguments' => [
'alias' => [
'type' => 'array',
'must' => 'y'
],
'description' => [
'type' => 'string',
'must' => 'y'
],
'params' => [//自定义参数
'type' => 'array',
'must' => 'n'
],
]
],
'topic' => [
'uri' => 'v3/message/topic',
'arguments' => [
'topics' => [
'type' => 'array',
'must' => 'y'
],
'description' => [
'type' => 'string',
'must' => 'y'
],
'params' => [//自定义参数
'type' => 'array',
'must' => 'n'
],
]
],
'multiTopic' => [
'uri' => 'v3/message/multi_topic',
'arguments' => [
'topics' => [
'type' => 'array',
'must' => 'y'
],
'topics_op' => [// UNION并集，INTERSECTION交集，EXCEPT差集
'type' => 'string',
'must' => 'y'
],
'description' => [
'type' => 'string',
'must' => 'y'
],
'params' => [//自定义参数
'type' => 'array',
'must' => 'n'
],
]
],
'all' => [
'uri' => 'v3/message/all',
'arguments' => [
'description' => [
'type' => 'string',
'must' => 'y'
],
'params' => [//自定义参数
'type' => 'array',
'must' => 'n'
],
]
],
];mipush エンティティのコンストラクター: 一連の構成の初期化を実装します
/**
* 初始化配置
*
* @param $string $os_type 系统类型
* @param $string $config 配置
* @param array $options 设置 [
* 'title' => 'string,标题',
* 'pass_through' => 'tinyint,0通知栏消息,1透传,默认0'
* 'notify_type' => 'tinyint,-1,1,2,3,4',
* 'time_to_send' => 'int, 定时推送, 毫秒'
* ]
* @param string $environment 环境
*/
public function __construct($os_type='', $config=array(), $options=array(), $environment='')
{
/* init environment */
if ($environment) {
$this->_environment = $environment;
}
if ($os_type === 'ios') {
$this->_host = self::$_environmentConfig['domain'][$this->_environment];// ios
}else{
$this->_host = self::$_environmentConfig['domain']['product'];// android
}
/* init option */
$this->_headers = [];
$this->_headers[] = 'Authorization: key=' . $config['secret'];
if ($os_type === 'android') {
$this->_options['restricted_package_name'] = $config['package_name'];
}
foreach ($this->_options as $k => &$v) {
if (in_array($k, $options)) {
$v = $options[$k];
}
}
}Mipush エンティティのマジック メソッド __call: パラメーターの検証と Xiaomi プッシュ インターフェイスの呼び出しを動的に実装します。これにより、将来的に新しい Xiaomi プッシュ インターフェイスを実装し、構成を実装できるようになります。
/**
* 魔术方法
*
* 重载对象方法
* @param string $name 小米推送方法名称
* @param array $arguments 请求参数
* @return mixed void||object
*/
public function __call($name,$arguments)
{
$arguments = $arguments[0];
$this->_function = $this->_functionDefine[$name];
$this->_url = $this->_host . $this->_function['uri'];
$this->dataCheck($arguments);
switch ($name) {
case 'regid':
$this->_data['registration_id'] = $arguments['registration_id'];
break;
case 'userAccount':
$this->_data['user_account'] = implode(',', $arguments['user_account']);
break;
case 'alias':
$this->_data['alias'] = implode(',', $arguments['alias']);
break;
case 'topic':
$this->_data['topic'] = $arguments['topic'];
break;
case 'multiTopic':
$this->_data['topics'] = implode(";$;", $arguments['topics']);
$this->_data['topic_op'] = $arguments['topic_op'];
break;
case 'all':
$this->_data['topics'] = implode(";$;", $topics);
$this->_data['topic_op'] = 'UNION';
break;
default:
throw new \Exception('Sorry, This function is useless in this version', 404);
break;
}
$this->_data['description'] = $arguments['description'];
if($arguments['params']) {
foreach ($arguments['params'] as $k => $v) {
$this->_data['extra.'.$k] = $v;// 自定义参数
}
}
if ($this->_osType === 'android') {
$this->_data = array_merge($this->_data, $this->_options);
}
}Xiaomi プッシュ エンティティを定義したら、mipush エンティティを使用してさまざまなデバイス タイプのオブジェクトをインスタンス化して生成し、curl を使用して並行してプッシュを開始するだけです。
/**
* 并行推送
*
* @param Mipush $mipush_ios ios端实体
* @param Mipush $mipush_android android端实体
* @return array 推送结果
*/
private static function curlRequest(Mipush $mipush_ios, Mipush $mipush_android)
{
$ch_ios = curl_init();
$ch_android = curl_init();
curl_setopt($ch_ios, CURLOPT_URL, $mipush_ios->_url);
curl_setopt($ch_ios, CURLOPT_POST, 1);
curl_setopt($ch_ios, CURLOPT_POSTFIELDS, $mipush_ios->_data);
curl_setopt($ch_ios, CURLOPT_HTTPHEADER, $mipush_ios->_headers);
curl_setopt($ch_ios, CURLOPT_RETURNTRANSFER, 1);
curl_setopt($ch_android, CURLOPT_URL, $mipush_android->_url);
curl_setopt($ch_android, CURLOPT_POST, 1);
curl_setopt($ch_android, CURLOPT_POSTFIELDS, $mipush_android->_data);
curl_setopt($ch_android, CURLOPT_HTTPHEADER, $mipush_android->_headers);
curl_setopt($ch_android, CURLOPT_RETURNTRANSFER, 1);
$mh = curl_multi_init();
curl_multi_add_handle($mh, $ch_ios);
curl_multi_add_handle($mh, $ch_android);
$running=null;
do {
curl_multi_exec($mh,$running);
} while($running > 0);
$result['ios'] = json_decode(curl_multi_getcontent($ch_ios), true);
$result['android'] = json_decode(curl_multi_getcontent($ch_android), true);
curl_multi_remove_handle($mh, $ch_ios);
curl_multi_remove_handle($mh, $ch_android);
curl_multi_close($mh);
return $result;
}以上です。上記の方法により、非常に少ないコードで Xiaomi SDK をカプセル化しました。現時点では、regid (登録 ID)、alias (エイリアス)、user_account (ユーザー アカウント)、topic (ラベル) のみを実装しています。 multi_topic (マルチラベル)、all (すべて) プッシュ。
使い方は？
これはまだpackagistに公開していませんが、興味のある学生は自分でググってみてください、笑~
composer require tigerb/easy-mipush
使用格式：
try {
Push::init(
['secret' => 'string,必传,ios密钥'],
['secret' => 'string,必传,android密钥', 'package_name' => 'string,必传,android包名']
[
'title' => 'string,非必传,消息通知自定义title',
'pass_through' => 'int,非必传,0通知栏消息,1透传,默认0',
'notify_type' => 'int,非必传,-1:默认所有,1:使用默认提示音提示,2:使用默认震动提示,4:使用默认led灯光提示',
'time_to_send' => 'int,非必传,定时推送,单位毫秒,默认0',
],
'string,develop开发环境，product生产环境, 默认develop'
);
$res = Push::toUse('string,小米push方法名', 'array, 该方法对应的参数');
echo json_encode($res, JSON_UNESCAPED_UNICODE);
} catch (Exception $e) {
echo $e->getMessage();
}
使用示例：
use Mipush\Push;
require './vendor/autoload.php';
try {
Push::init(
['secret' => 'test'],
['secret' => 'test', 'package_name' => 'com.test'],
[
'title' => 'test',
'pass_through' => 0,
'notify_type' => -1,
'time_to_send' => 0,
],
'develop'
);
$res = Push::toUse('userAccount', [
'user_account' => [1],
'description' => 'test'
]);
echo json_encode($res, JSON_UNESCAPED_UNICODE);
} catch (Exception $e) {
echo $e->getMessage();
}声明：
この記事の内容はネチズンが自主的に寄稿したものであり、著作権は原著者に帰属します。このサイトは、それに相当する法的責任を負いません。盗作または侵害の疑いのあるコンテンツを見つけた場合は、admin@php.cn までご連絡ください。