环信即时通讯---php版

<?php
/**
 * 环信IM
 * Created by PhpStorm.
 * User: chao
 * Date: 2020/12/9
 * Time: 4:34 PM
 */
10 
class HxChat{
    private $app_key = '123456#abcd';
    private $client_id = 'hhkhkkkhh';
    private $client_secret = 'uiuriwrinncj';
    private $url = "https://a1.easemob.com/123456/abcd"; //要与$app_key值保持一致

    /*
     * 获取APP管理员Token
     */
    function __construct()
    {
        $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'];
    }

    /**
     * 注册单个用户(开放)
     * @param $username
     * @param $password
     * @param string $nickname
     */
    public function hx_open_register($username, $password, $nickname='')
    {
        $url = $this->url . "/users";
        $data = array(
            'username'=>$username,
            'password'=>$password,
            'nickname'=>$nickname,
        );
        $header = array(
            'Content-Type: application/json',
        );

        return $this->curl($url, $data, $header, 'POST');
    }

    /**
     * 注册单个用户(授权)
     * @param $username
     * @param $password
     * @param string $nickname
     */
    public function hx_auth_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');

    }

    /**
     * 添加好友
     * @param $owner_username  要添加好友的用户名
     * @param $friend_username  好友用户名
     * @return mixed
     */
    public function hx_add_friend($owner_username, $friend_username)
    {
        $url = $this->url . "/users/${owner_username}/contacts/users/${friend_username}";
        $header = array(
            'Content-Type: application/json',
            'Authorization: Bearer '.$this->token,
        );

        return $this->curl($url, '' , $header, 'POST');
    }

    /**
     * 移除好友
     * @param $owner_username
     * @param $friend_username
     * @return mixed
     */
    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");
    }

    /**
     * 获取好友列表
     * @param $owner_username
     * @return mixed
     */
    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");
    }

    /**
     * 发送文本消息
     * @param $sender 发送者
     * @param $receiver 接收者
     * @param $msg  消息
     * @return mixed
     */
    public function hx_send_txt_msg($sender, $receiver, $msg)
    {
        $url = $this->url . "/messages";
        $header = array(
            'Authorization: Bearer ' . $this->token,
            'Content-Type: application/json'
        );
        $data = array(
            'target_type'=> 'users',
            'target'=>[$receiver],
            'msg'=>['msg'=>$msg, 'type'=>'txt'],
            'from'=>$sender,
        );
        return $this->curl($url, $data, $header, "POST");
    }

    /**
     * curl
     * @param $url
     * @param $data
     * @param bool $header
     * @param string $method
     * @return mixed
     */
    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;
    }
}