环信即时通讯-服务器端集成(REST API)-php版demo

Myth丶恋晨 2022-08-19 08:27 80阅读 0赞

原文地址：http://www.thinkphp.cn/code/1259.html

注意问题：获取APP管理员Token有次数限制，获取后需要缓存起来。

<?php  
 class Hxcall  
 \{  
      
    private $app\_key = 'qqqqqq\#aaaaaa';  
    private $client\_id = 'sdasdasdasd';  
    private $client\_secret = 'sdsdsdsdsd';  
    private $url = "https://a1.easemob.com/qqqqqq/aaaaaa";  
    /\*  
     \* 获取APP管理员Token  
     \*/  
    function \_\_construct()  
    \{  
      if(file\_exists('./Application/Library/Token/token') && time()-filemtime('./Application/Library/Token/token')<=86400)\{  
    $this->token = file\_get\_contents('./Application/Library/Token/token');  
     \}else\{

$url = $this->url . "/token";  
        $data = array(  
            'grant\_type' => 'client\_credentials',  
            'client\_id' => $this->client\_id,  
            'client\_secret' => $this->client\_secret  
        );  
        $rs = json\_decode($this->curl($url, $data), true);

$this->token = $rs\['access\_token'\];

file\_put\_contents('./Application/Library/Token/token', $rs\['access\_token'\]);

\}  
    \}  
    /\*  
     \* 注册IM用户(授权注册)  
     \*/  
    public function hx\_register($username, $password, $nickname)  
    \{  
        $url = $this->url . "/users";  
        $data = array(  
            'username' => $username,  
            'password' => $password,  
            'nickname' => $nickname  
        );  
        $header = array(  
            'Content-Type: application/json',  
            'Authorization: Bearer ' . $this->token  
        );  
        return $this->curl($url, $data, $header, "POST");  
    \}  
    /\*  
     \* 给IM用户的添加好友  
     \*/  
    public function hx\_contacts($owner\_username, $friend\_username)  
    \{  
        $url = $this->url . "/users/$\{owner\_username\}/contacts/users/$\{friend\_username\}";  
        $header = array(  
            'Authorization: Bearer ' . $this->token  
        );  
        return $this->curl($url, "", $header, "POST");  
    \}  
    /\*  
     \* 解除IM用户的好友关系  
     \*/  
    public function hx\_contacts\_delete($owner\_username, $friend\_username)  
    \{  
        $url = $this->url . "/users/$\{owner\_username\}/contacts/users/$\{friend\_username\}";  
        $header = array(  
            'Authorization: Bearer ' . $this->token  
        );  
        return $this->curl($url, "", $header, "DELETE");  
    \}  
    /\*  
     \* 查看好友  
     \*/  
    public function hx\_contacts\_user($owner\_username)  
    \{  
        $url = $this->url . "/users/$\{owner\_username\}/contacts/users";  
        $header = array(  
            'Authorization: Bearer ' . $this->token  
        );  
        return $this->curl($url, "", $header, "GET");  
    \}  
      
    /\* 发送文本消息 \*/  
    public function hx\_send($sender, $receiver, $msg)  
    \{  
        $url = $this->url . "/messages";  
        $header = array(  
            'Authorization: Bearer ' . $this->token  
        );  
        $data = array(  
            'target\_type' => 'users',  
            'target' => array(  
                '0' => $receiver  
            ),  
            'msg' => array(  
                'type' => "txt",  
                'msg' => $msg  
            ),  
            'from' => $sender,  
            'ext' => array(  
                'attr1' => 'v1',  
                'attr2' => "v2"  
            )  
        );  
        return $this->curl($url, $data, $header, "POST");  
    \}  
    /\* 查询离线消息数 获取一个IM用户的离线消息数 \*/  
    public function hx\_msg\_count($owner\_username)  
    \{  
        $url = $this->url . "/users/$\{owner\_username\}/offline\_msg\_count";  
        $header = array(  
            'Authorization: Bearer ' . $this->token  
        );  
        return $this->curl($url, "", $header, "GET");  
    \}  
      
    /\*  
     \* 获取IM用户\[单个\]  
     \*/  
    public function hx\_user\_info($username)  
    \{  
        $url = $this->url . "/users/$\{username\}";  
        $header = array(  
            'Authorization: Bearer ' . $this->token  
        );  
        return $this->curl($url, "", $header, "GET");  
    \}  
    /\*  
     \* 获取IM用户\[批量\]  
     \*/  
    public function hx\_user\_infos($limit)  
    \{  
        $url = $this->url . "/users?$\{limit\}";  
        $header = array(  
            'Authorization: Bearer ' . $this->token  
        );  
        return $this->curl($url, "", $header, "GET");  
    \}  
    /\*  
     \* 重置IM用户密码  
     \*/  
    public function hx\_user\_update\_password($username, $newpassword)  
    \{  
        $url = $this->url . "/users/$\{username\}/password";  
        $header = array(  
            'Authorization: Bearer ' . $this->token  
        );  
        $data\['newpassword'\] = $newpassword;  
        return $this->curl($url, $data, $header, "PUT");  
    \}  
      
    /\*  
     \* 删除IM用户\[单个\]  
     \*/  
    public function hx\_user\_delete($username)  
    \{  
        $url = $this->url . "/users/$\{username\}";  
        $header = array(  
            'Authorization: Bearer ' . $this->token  
        );  
        return $this->curl($url, "", $header, "DELETE");  
    \}  
    /\*  
     \* 修改用户昵称  
     \*/  
    public function hx\_user\_update\_nickname($username, $nickname)  
    \{  
        $url = $this->url . "/users/$\{username\}";  
        $header = array(  
            'Authorization: Bearer ' . $this->token  
        );  
        $data\['nickname'\] = $nickname;  
        return $this->curl($url, $data, $header, "PUT");  
    \}  
    /\*  
     \*  
     \* curl  
     \*/  
    private function curl($url, $data, $header = false, $method = "POST")  
    \{  
        $ch = curl\_init($url);  
        curl\_setopt($ch, CURLOPT\_URL, $url);  
        curl\_setopt($ch, CURLOPT\_RETURNTRANSFER, 1);  
        if ($header) \{  
            curl\_setopt($ch, CURLOPT\_HTTPHEADER, $header);  
        \}  
        curl\_setopt($ch, CURLOPT\_CUSTOMREQUEST, $method);  
        if ($data) \{  
            curl\_setopt($ch, CURLOPT\_POSTFIELDS, json\_encode($data));  
        \}  
        curl\_setopt($ch, CURLOPT\_SSL\_VERIFYPEER, false);  
        curl\_setopt($ch, CURLOPT\_SSL\_VERIFYHOST, false);  
        $ret = curl\_exec($ch);  
        return $ret;  
    \}  
 \}  
 $rs = new Hxcall();  
 // 注册的用户  
 //echo $rs->hx\_register('qwerasd', 'qazwsx', '福州123' );  
 // 给IM用户的添加好友  
 // echo $rs->hx\_contacts('admin888', 'qwerasd');  
 /\* 发送文本消息 \*/  
 // echo $rs->hx\_send('213123','admin888','dfadsr214wefaedf');  
 /\* 消息数统计 \*/  
 // echo $rs->hx\_msg\_count('admin888');  
 /\* 获取IM用户\[单个\] \*/  
 // echo $rs->hx\_user\_info('admin888');  
 /\* 获取IM用户\[批量\] \*/  
 echo $rs->hx\_user\_infos('20');  
 /\* 删除IM用户\[单个\] \*/  
 // echo $rs->hx\_user\_delete('wwwwww');  
 /\* 修改用户昵称 \*/  
 // echo $rs->hx\_user\_update\_nickname('asaxcfasdd','网络科技');  
 /\* 重置IM用户密码 \*/  
 // echo $rs->hx\_user\_update\_password('asaxcfasdd','asdad');  
 /\* 解除IM用户的好友关系 \*/  
 // echo $rs->hx\_contacts\_delete('admin888', 'qqqqqqqq');  
 /\* 查看好友 \*/  
 //echo $rs->hx\_contacts\_user('admin888');