利用php重載和curl的并行方式優(yōu)雅的封裝小米推送sdk

Guakin_Huang 發(fā)布于2019-06-27 14:39 / 3380人閱讀

摘要：背景前段時(shí)間遷移小米推送部分代碼，這部分之前是其他人負(fù)責(zé)的。并行推送端實(shí)體端實(shí)體推送結(jié)果以上就是這些了，通過(guò)以上的方式我們就用很少的代碼封裝了一個(gè)小米，目前只實(shí)現(xiàn)了按登記別名用戶賬號(hào)標(biāo)簽多標(biāo)簽全體推送。

背景

前段時(shí)間遷移小米推送部分代碼，這部分之前是其他人負(fù)責(zé)的。讀了代碼，發(fā)現(xiàn)了兩點(diǎn)：

所有接口的實(shí)現(xiàn)除了url和傳參基本都是一致的

android和ios的設(shè)備需要分別推送一次

剛好這段時(shí)間了解了一下php的重載概念【動(dòng)態(tài)的創(chuàng)建類屬型和方法，不同于java等的參數(shù)不同方法名相通的概念，具體的概念可以RTFM】和curl的并發(fā)方式，所以

對(duì)于以上第一點(diǎn)：是否可以利用php的重載概念，用魔術(shù)方法__call()動(dòng)態(tài)的變更接口調(diào)用的url參數(shù)和請(qǐng)求參數(shù)，去實(shí)現(xiàn)對(duì)小米推送不同接口的調(diào)用，也就是說(shuō)我們所有的調(diào)用邏輯都是實(shí)現(xiàn)在__call這一個(gè)方法中，卻對(duì)外提供小米推送不同接口的調(diào)用方法，這樣就會(huì)極大的簡(jiǎn)化代碼

對(duì)于以上第二點(diǎn)：是否可以利用curl的并行方式一次性推送給android和ios設(shè)備，這樣理論上我們可以減少一次推送調(diào)用的時(shí)間，因?yàn)槲覀儾恍枰偃サ却o一類設(shè)備推送完了，再去推送給另一類設(shè)備

具體實(shí)現(xiàn) 接下來(lái)，我們開(kāi)始造代碼。首先，構(gòu)造一個(gè)mipush的實(shí)體，實(shí)體的成員屬性包括：運(yùn)行環(huán)境、初始化的一些配置參數(shù)、所實(shí)現(xiàn)的小米接口的信息(接口uri和參數(shù)等)

    /**
     * 運(yùn)行環(huán)境 develop：開(kāi)發(fā)環(huán)境 product：生產(chǎn)環(huán)境
     * @var string
     */
    private $_environment = "develop";

    /**
     * 設(shè)備系統(tǒng)類型 android ios
     * @var string
     */
    private $_osType      = "";

    /**
     * 小米推送域名
     * @var string
     */
    private $_host        = "";

    /**
     * 請(qǐng)求頭
     * @var string
     */
    private $_headers     = "";

    /**
     * 接口url
     * @var string
     */
    private $_url         = "";

    /**
     * 調(diào)用的接口方法名稱
     * @var array
     */
    private $_function    = [];

    /**
     * 請(qǐng)求參數(shù)
     * @var array
     */
    private $_data        = [];

    /**
     * 小米推送設(shè)置
     * @var array
     */
    private $_options = [
        "title"                   => "消息通知自定義title",
        "restricted_package_name" => "",
        "pass_through"            => 0, // 0 通知欄消息 1 透?jìng)?        "notify_type"             => -1, // -1:默認(rèn)所有,1:使用默認(rèn)提示音提示,2:使用默認(rèn)震動(dòng)提示,4:使用默認(rèn)led燈光提示
        "time_to_send"             => 0, // 定時(shí)推送 單位毫秒 默認(rèn)0
    ];

    /**
     * 運(yùn)行環(huán)境配置
     * @var array
     */
    private static $_environmentConfig = [
        "domain" => [
            "product"  => "https://api.xmpush.xiaomi.com/",
            "develop"  => "https://sandbox.xmpush.xiaomi.com/"
        ],
    ];

    /**
     * 小米推送接口信息定義
     * 
     * url/請(qǐng)求參數(shù)
     * @var array
     */
    private $_functionDefine = [
        "regid" => [
            "uri" => "v3/message/regid",
            "arguments" => [
                "registration_id" => [
                    "type" => "array",
                    "must" => "y"
                ],
                "description" => [
                    "type" => "string",
                    "must" => "y"
                ],
                "params" => [//自定義參數(shù)
                    "type" => "array",
                    "must" => "n"
                ],
            ]
        ],
        "userAccount" => [
            "uri" => "v2/message/user_account",
            "arguments" => [
                "user_account" => [
                    "type" => "array",
                    "must" => "y"
                ],
                "description" => [
                    "type" => "string",
                    "must" => "y"
                ],
                "params" => [//自定義參數(shù)
                    "type" => "array",
                    "must" => "n"
                ],
            ]
        ],
        "alias" => [
            "uri" => "v3/message/alias",
            "arguments" => [
                "alias" => [
                    "type" => "array",
                    "must" => "y"
                ],
                "description" => [
                    "type" => "string",
                    "must" => "y"
                ],
                "params" => [//自定義參數(shù)
                    "type" => "array",
                    "must" => "n"
                ],
            ]
        ],
        "topic" => [
            "uri" => "v3/message/topic",
            "arguments" => [
                "topics" => [
                    "type" => "array",
                    "must" => "y"
                ],
                "description" => [
                    "type" => "string",
                    "must" => "y"
                ],
                "params" => [//自定義參數(shù)
                    "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" => [//自定義參數(shù)
                    "type" => "array",
                    "must" => "n"
                ],
            ]
        ],
        "all" => [
            "uri" => "v3/message/all",
            "arguments" => [
                "description" => [
                    "type" => "string",
                    "must" => "y"
                ],
                "params" => [//自定義參數(shù)
                    "type" => "array",
                    "must" => "n"
                ],
            ]
        ],
    ];

mipush實(shí)體的構(gòu)造函數(shù)：實(shí)現(xiàn)對(duì)一系列配置的初始化

/**
     * 初始化配置
     * 
     * @param $string $os_type 系統(tǒng)類型
     * @param $string $config  配置
     * @param array   $options 設(shè)置 [
     *                        "title"        => "string,標(biāo)題", 
     *                        "pass_through" => "tinyint,0通知欄消息,1透?jìng)?默認(rèn)0"
     *                        "notify_type"  => "tinyint,-1,1,2,3,4",
     *                        "time_to_send" => "int, 定時(shí)推送, 毫秒"
     *                        ]
     * @param string  $environment 環(huán)境
     */
    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實(shí)體的魔法方法__call：動(dòng)態(tài)實(shí)現(xiàn)對(duì)小米推送接口的參數(shù)驗(yàn)證和調(diào)用，以至于我們未來(lái)實(shí)現(xiàn)新的小米推送接口及實(shí)現(xiàn)配置就可以。

/**
     * 魔術(shù)方法
     * 
     * 重載對(duì)象方法
     * @param  string $name      小米推送方法名稱
     * @param  array  $arguments 請(qǐng)求參數(shù)
     * @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;// 自定義參數(shù)
            }
        }
        if ($this->_osType === "android") {
            $this->_data = array_merge($this->_data, $this->_options);
        }
    }

定義完小米推送實(shí)體后，我們只需要通過(guò)mipush這個(gè)實(shí)體，實(shí)例化生產(chǎn)不同設(shè)備類型的對(duì)象，再由curl并行的方式發(fā)起推送即可。

/**
     * 并行推送
     * 
     * @param  Mipush $mipush_ios     ios端實(shí)體
     * @param  Mipush $mipush_android android端實(shí)體
     * @return array                  推送結(jié)果
     */
    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;
    }

以上就是這些了，通過(guò)以上的方式我們就用很少的代碼封裝了一個(gè)小米sdk，目前只實(shí)現(xiàn)了按regid(登記id),alias(別名),user_account(用戶賬號(hào)),topic(標(biāo)簽), multi_topic(多標(biāo)簽),all(全體)推送。

如何使用？

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透?jìng)?默認(rèn)0",
          "notify_type"  => "int,非必傳,-1:默認(rèn)所有,1:使用默認(rèn)提示音提示,2:使用默認(rèn)震動(dòng)提示,4:使用默認(rèn)led燈光提示",
          "time_to_send" => "int,非必傳,定時(shí)推送,單位毫秒,默認(rèn)0",
        ],
        "string,develop開(kāi)發(fā)環(huán)境，product生產(chǎn)環(huán)境, 默認(rèn)develop"
        );  
    $res = Push::toUse("string,小米push方法名", "array, 該方法對(duì)應(yīng)的參數(shù)");
    echo json_encode($res, JSON_UNESCAPED_UNICODE);
} catch (Exception $e) {
    echo $e->getMessage();
}

使用示例：
use MipushPush;

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();
}

最后，第一次寫(xiě)這種文章，寫(xiě)的不是很好，寫(xiě)的不對(duì)的地方謝謝大家留言指證出來(lái)，其次，還沒(méi)驗(yàn)證過(guò)這里使用魔術(shù)方法的性能消耗，因?yàn)橹坝锌催^(guò)鳥(niǎo)哥的文章不贊成使用魔術(shù)方法，歡迎大家留言指證，謝謝。

完整代碼地址： https://github.com/TIGERB/eas...

掃面下方二維碼關(guān)注我的技術(shù)公眾號(hào)，及時(shí)為大家推送我的原創(chuàng)技術(shù)分享

云服務(wù)器 GPU云服務(wù)器 AppKey和推送證書(shū)的淵源按照云計(jì)算服務(wù)的方式和服務(wù)對(duì)象的范圍 sdk和api的優(yōu)點(diǎn) php的sdk

文章版權(quán)歸作者所有，未經(jīng)允許請(qǐng)勿轉(zhuǎn)載,若此文章存在違規(guī)行為，您可以聯(lián)系管理員刪除。

轉(zhuǎn)載請(qǐng)注明本文地址：http://systransis.cn/yun/21940.html

發(fā)表評(píng)論

登陸后可評(píng)論

0條評(píng)論

Guakin_Huang

男|高級(jí)講師

我要關(guān)注我要私信

TA的文章

RangCloud：雙十一促銷，全年最低價(jià)，香港CN2+BGP線路VPS/5折優(yōu)惠，1核/1G套餐月

閱讀 1719·2021-11-02 14:47
好看漂亮的html5網(wǎng)頁(yè)特效學(xué)習(xí)筆記(5)_弧形菜單

閱讀 3664·2019-08-30 15:44
如果你在2018面試前端，那這篇文章最好看一看！

閱讀 1353·2019-08-29 16:42
重學(xué)前端學(xué)習(xí)筆記（二十三）--狹義的文檔對(duì)象DOM

閱讀 1746·2019-08-26 13:53
vue實(shí)現(xiàn)自定義dialog組件

閱讀 949·2019-08-26 10:41
WebGL three.js學(xué)習(xí)筆記使用粒子系統(tǒng)模擬時(shí)空隧道（蟲(chóng)洞）

閱讀 3479·2019-08-23 17:10
H5拍照、選擇圖片上傳組件核心

閱讀 616·2019-08-23 14:24
微信小程序自定義組件(一)

閱讀 1734·2019-08-23 11:59

成人国产在线小视频_日韩寡妇人妻调教在线播放_色成人www永久在线观看_2018国产精品久久_亚洲欧美高清在线30p_亚洲少妇综合一区_黄色在线播放国产_亚洲另类技巧小说校园_国产主播xx日韩_a级毛片在线免费

資訊專欄INFORMATION COLUMN

上云采購(gòu)季！| 2核2G4M爆款云服務(wù)器低至59元/年，更有多臺(tái)、長(zhǎng)期優(yōu)惠，快來(lái)選購(gòu)！

利用php重載和curl的并行方式優(yōu)雅的封裝小米推送sdk

相關(guān)文章

**從小米推送 php 服務(wù)端框架中看看代碼該怎么寫(xiě)**

Java字節(jié)碼修改神器HiBeaver：黑掉你的SDK

發(fā)表評(píng)論

0條評(píng)論

Guakin_Huang

男|高級(jí)講師

TA的文章

RangCloud：雙十一促銷，全年最低價(jià)，香港CN2+BGP線路VPS/5折優(yōu)惠，1核/1G套餐月

好看漂亮的html5網(wǎng)頁(yè)特效學(xué)習(xí)筆記(5)_弧形菜單

如果你在2018面試前端，那這篇文章最好看一看！

重學(xué)前端學(xué)習(xí)筆記（二十三）--狹義的文檔對(duì)象DOM

vue實(shí)現(xiàn)自定義dialog組件

WebGL three.js學(xué)習(xí)筆記使用粒子系統(tǒng)模擬時(shí)空隧道（蟲(chóng)洞）

H5拍照、選擇圖片上傳組件核心

微信小程序自定義組件(一)

最新活動(dòng)

資訊專欄INFORMATION COLUMN

上云采購(gòu)季！| 2核2G4M爆款云服務(wù)器低至59元/年，更有多臺(tái)、長(zhǎng)期優(yōu)惠，快來(lái)選購(gòu)！

利用php重載和curl的并行方式優(yōu)雅的封裝小米推送sdk

相關(guān)文章

發(fā)表評(píng)論

0條評(píng)論

男|高級(jí)講師

TA的文章

最新活動(dòng)

上云采購(gòu)季！| 2核2G4M爆款云服務(wù)器低至59元/年，更有多臺(tái)、長(zhǎng)期優(yōu)惠，快來(lái)選購(gòu)！