当PHP作为客户端去对接resuful api的时候，手动封装一个专门请求api的类，代码如下
<?php
namespace app\api\service;
/**
* CURL数据请求管理器
* Class Http
*/
class HttpService
{
//注意如果请求内容为json，则要把post请求中的form-data 进行json_encode已经修改对应的header
public static $headers = ['Content-Type:application/x-www-form-urlencoded;charset=UTF-8;'];
/**
* 设置头信息
* @param array $headers 头信息
*/
public static function setHeader($headers){
self::$headers = array_merge(self::$headers,$headers);
}
/**
* 以get模拟网络请求
* @param string $url HTTP请求URL地址
* @param array $query GET请求参数
* @param array $options CURL参数
* @return boolean|string
*/
public static function get($url, $query = [], $options = []){
$options['query'] = $query;
return self::request('get', $url, $options);
}
/**
* 以POST模拟网络请求
* @param string $url HTTP请求URL地址
* @param array $data POST请求数据
* @param array $options CURL参数
* @return boolean|string
*/
public static function post($url, $data = [], $options = []){
$options['data'] = $data;
return self::request('post', $url, $options);
}
/**
* 以DELETE模拟网络请求
* @param string $url HTTP请求URL地址
* @param array $data DELETE请求数据
* @param array $options CURL参数
* @return boolean|string
*/
public static function delete($url,$query = [],$options = []){
$options['query'] = $query;
return self::request('delete', $url, $options);
}
/**
* 以PUT模拟网络请求
* @param string $url HTTP请求URL地址
* @param array $data DELETE请求数据
* @param array $options CURL参数
* @return boolean|string
*/
public static function put($url,$data = [],$options = []){
$options['data'] = $data;
return self::request('put', $url, $options);
}
/**
* CURL模拟网络请求
* @param string $method 请求方法
* @param string $url 请求方法
* @param array $options 请求参数[headers,data]
* @return boolean|string
*/
public static function request($method, $url, $options = []){
$curl = curl_init();
// GET 参数设置
if (!empty($options['query'])) {
$url .= (stripos($url, '?') !== false ? '&' : '?') . http_build_query($options['query']);
}
// 浏览器代理设置
curl_setopt($curl, CURLOPT_USERAGENT, self::getUserAgent());
// CURL 头信息设置
if (!empty($options['headers'])) {
self::$headers = array_merge(self::$headers,$options['headers']);
}
curl_setopt($curl, CURLOPT_HTTPHEADER, self::$headers);
// Cookie 信息设置
if (!empty($options['cookie'])) {
curl_setopt($curl, CURLOPT_COOKIE, $options['cookie']);
}
if (!empty($options['cookie_file'])) {
curl_setopt($curl, CURLOPT_COOKIEJAR, $options['cookie_file']);
curl_setopt($curl, CURLOPT_COOKIEFILE, $options['cookie_file']);
}
// POST 数据设置
if (strtolower($method) === 'post') {
curl_setopt($curl, CURLOPT_POST, true);
curl_setopt($curl, CURLOPT_POSTFIELDS, self::buildQueryData($options['data']));
}
//PUT 数据设置
if (strtolower($method) === 'put') {
curl_setopt($curl, CURLOPT_POSTFIELDS,self::buildQueryData($options['data']));
}
// 请求超时设置
if (isset($options['timeout']) && is_numeric($options['timeout'])) {
curl_setopt($curl, CURLOPT_TIMEOUT, $options['timeout']);
} else {
curl_setopt($curl, CURLOPT_TIMEOUT, 60);
}
curl_setopt($curl, CURLOPT_URL, $url);
curl_setopt($curl, CURLOPT_HEADER, false);
curl_setopt($curl, CURLOPT_AUTOREFERER, true);
curl_setopt($curl, CURLOPT_FOLLOWLOCATION, true);
curl_setopt($curl, CURLOPT_RETURNTRANSFER, true);
curl_setopt($curl, CURLOPT_SSL_VERIFYPEER, false);
curl_setopt($curl, CURLOPT_SSL_VERIFYHOST, false);
curl_setopt($curl,CURLINFO_HEADER_OUT,true);
curl_setopt($curl, CURLOPT_CUSTOMREQUEST, strtoupper($method));
$content = json_decode(curl_exec($curl),true);
$content['status'] = curl_getinfo ( $curl, CURLINFO_HTTP_CODE );
if($content['code'] != 200) {
//在这里处理异常信息
}
curl_close($curl);
return $content;
}
/**
* POST数据过滤处理
* @param array $data 需要处理的数据
* @param boolean $build 是否编译数据
* @return array|string
*/
private static function buildQueryData($data, $build = true)
{
if (!is_array($data)) return $data;
foreach ($data as $key => $value) if (is_object($value) && $value instanceof \CURLFile) {
$build = false;
} elseif (is_string($value) && class_exists('CURLFile', false) && stripos($value, '@') === 0) {
if (($filename = realpath(trim($value, '@'))) && file_exists($filename)) {
list($build, $data[$key]) = [false, new \CURLFile($filename)];
}
}
return $build ? http_build_query($data) : $data;
}
/**
* 获取浏览器代理信息
* @return string
*/
private static function getUserAgent(){
if (!empty($_SERVER['HTTP_USER_AGENT'])) return $_SERVER['HTTP_USER_AGENT'];
$userAgents = [
"Mozilla/5.0 (Windows NT 6.1; rv:2.0.1) Gecko/20100101 Firefox/4.0.1",
"Mozilla/5.0 (Windows NT 6.1) AppleWebKit/536.11 (KHTML, like Gecko) Chrome/20.0.1132.57 Safari/536.11",
"Mozilla/5.0 (Windows NT 10.0; WOW64; rv:38.0) Gecko/20100101 Firefox/38.0",
"Mozilla/5.0 (Windows NT 10.0; WOW64; Trident/7.0; .NET4.0C; .NET4.0E; .NET CLR 2.0.50727; .NET CLR 3.0.30729; .NET CLR 3.5.30729; InfoPath.3; rv:11.0) like Gecko",
"Mozilla/5.0 (Windows; U; Windows NT 6.1; en-us) AppleWebKit/534.50 (KHTML, like Gecko) Version/5.1 Safari/534.50",
"Mozilla/4.0 (compatible; MSIE 8.0; Windows NT 6.0; Trident/4.0)",
"Mozilla/5.0 (compatible; MSIE 9.0; Windows NT 6.1; Trident/5.0)",
"Mozilla/5.0 (Macintosh; Intel Mac OS X 10.6; rv:2.0.1) Gecko/20100101 Firefox/4.0.1",
"Mozilla/5.0 (Macintosh; Intel Mac OS X 10_7_0) AppleWebKit/535.11 (KHTML, like Gecko) Chrome/17.0.963.56 Safari/535.11",
];
return $userAgents[array_rand($userAgents, 1)];
}
}
调用(本文对接环信为例) base
<?php
namespace app\api\service\sdk\huanxin;
use app\api\service\HttpService;
/**
* @author jinanav
* @desc 环信基础务器类
*/
class BaseService {
//配置参数
protected $config = [];
//令牌
protected $token = '';
/**
* BaseService constructor.初始化
*/
public function __construct(array $config = []){
$this->config = config('huanxin.');
!empty($config) && $this->config = array_merge($this->config,$config);
empty($this->config) && ajaxReturn(500,'配置参数异常');
$this->token = $this->getToken();
HttpService::setHeader(['Authorization:Bearer '.$this->token]);
}
/**
* 获取管理员权限
* @author jinanav
* @return array | string
*/
public function getToken(){
//获取环信token
$token = cache('huanxin_token');
if(!empty($token) && time() < $token['expires_in']) return $token['access_token'];
//如果已过期
$token = HttpService::post($this->config['url_fix'].'token', [
'grant_type' => 'client_credentials',
'client_id' => $this->config['client_id'],
'client_secret' => $this->config['client_secret']
]);
//缓存token
$token['expires_in'] = time() + intval($token['expires_in']) - 600;
cache('huanxin_token',$token);
return $token['access_token'];
}
}
调用用户类
<?php
namespace app\api\service\sdk\huanxin\user;
use app\api\service\HttpService;
use app\api\service\sdk\huanxin\BaseService;
/**
* @author jinanav
* @desc 环信用户管理服务类
*/
class UserService extends BaseService {
/**
* 注册单个用户
* @author jinanav
* @return mixed
*/
public function registerUser($username,$password,$nickname){
$url = $this->config['url_fix'].'users';
$param = [
'username' => $username,
'password' => $password,
'nickname' => $nickname
];
return HttpService::post($url,$param);
}
/**
* 批量注册用户
* @author jinanav
* @param array $regArray 批量用户列表
* @return mixed
*/
public function registerMoreUser(array $regArray){
$url = $this->config['url_fix'].'users';
return HttpService::post($url,$regArray);
}
/**
* 获取单个用户
* @author jinanav
* @param string $username 用户名 （实际上是手机号）
* @return mixed
*/
public function getUser(string $username){
$url = $this->config['url_fix'].'users/'.$username;
return HttpService::get($url);
}
/**
* 获取批量用户
* @author jinanav
* @return mixed
*/
public function getMoreUser($limit = 15,$cursor = ''){
$url = $this->config['url_fix'].'users';
$param = empty($cursor) ? ['limit' => $limit,'cursor' => $limit] : [];
return HttpService::get($url,$param);
}
/**
* 删除单个用户
* @author jinanav
* @return mixed
*/
public function delUser($username){
$url = $this->config['url_fix'].'users/'.$username;
return HttpService::delete($url);
}
/**
* 删除多个用户
* @author jinanav
* @param int $limit 用户数目
* @return mixed
*/
public function delMoreUser($limit = 0){
$url = $this->config['url_fix'].'users/';
return HttpService::delete($url,['limit' => $limit]);
}
/**
* 更改密码
* @author jinanav
* @param string $username 用户名
* @param string $password 密码
* @return mixed
*/
public function changePassword($username,$password){
$url = $this->config['url_fix'].'users/'.$username.'/password';
return HttpService::put($url,['newpassword'=>$password]);
}
/**
* 设置推送昵称
* @author jinanav
* @param string $nickname 推送昵称
* @return mixed
*/
public function setNickname($nickname){
$url = $this->config['url_fix'].'users/nickname';
return HttpService::put($url,['nickname'=>$nickname]);
}
/**
* 设置推送消息展示方式
* @author jinanav
* @param int $notification_display_style 展示方式 “0”仅通知，“1“通知以及消息详情
* @return mixed
*/
public function notification($username,$notification_display_style){
$url = $this->config['url_fix'].'users/'.$username;
return HttpService::put($url,['notification_display_style'=>$notification_display_style]);
}
/**
* 设置免打扰
* @author jinanav
* @param string $username 用户名
* @param int $disturbing 是否免打扰，“0”代表免打扰关闭，“1”免打扰开启
* @param int $start 免打扰起始时间，单位是小时
* @param int $end 免打扰结束时间，单位是小时
* @return mixed
*/
public function disturbing($username,$disturbing,$start,$end){
$url = $this->config['url_fix'].'users/'.$username;
return HttpService::put($url,[
'notification_no_disturbing' => $disturbing,
'notification_no_disturbing_start' => $start,
'notification_no_disturbing_end' => $end,
]);
}
/**
* 用户账号禁用
* @author jinanav
* @param string $username 用户名
* @return mixed
*/
public function deactivate($username){
$url = $this->config['url_fix'].'users/'.$username.'/deactivate';
return HttpService::post($url);
}
/**
* 用户账号解禁
* @author jinanav
* @param string $username 用户名
* @return mixed
*/
public function activate($username){
$url = $this->config['url_fix'].'users/'.$username.'/activate';
return HttpService::post($url);
}
/**
* 强制下线
* @author jinanav
* @param string $username 用户名
* @return mixed
*/
public function disconnect($username){
$url = $this->config['url_fix'].'users/'.$username.'/disconnect';
return HttpService::post($url);
}
}
