融云rongCloud聊天室的使用

融云提供了两种途径的接口，
一个是app端，一个是服务器端的。

app端

1.连接融云,监听消息

rong = api.require('rongCloud2');
rong.init(function(ret, err) {
});
rong.connect({
    token: user.rong_token
},function(ret, err) {
    setOnReceiveMessageListener();
});

// 监听消息接收
function setOnReceiveMessageListener() {
    rong.setOnReceiveMessageListener(function(ret, err) {
        api.toast({ msg: JSON.stringify(ret.result.message) });
    })
}

这个监听方法是核心了，能够监听各种类型的消息，PRIVATE 单聊，DISCUSSION 讨论组，GROUP 群组，CHATROOM 聊天室，SYSTEM 系统，CUSTOMER_SERVICE 客服。
用户加入，用户离开，用户发送消息等都可以通过这个接口来监听。

2.创建并加入聊天室

function joinChatRoom(room_id) {
    // 默认会创建聊天室
    rong.joinChatRoom({
        chatRoomId: room_id,
        defMessageCount: 20
    }, function(ret, err) {
        // alert(JSON.stringify(ret));
    })
}

传入room_id ,如果聊天室不存在，就会创建，如果存在则加入。

3.退出聊天室

function quitChatRoom(room_id) {
    rong.quitChatRoom({
        chatRoomId: room_id
    }, function(ret, err) {
        if (ret.status == 'success')
            api.toast({ msg: JSON.stringify(ret.status) });
        else
            api.toast({ msg: err.code });
    })
}

融云系统会统计聊天室中的人数，人员信息。只有聊天室中的人，才能收到相互之间发送的消息。

4.发送消息

function sendRoomTextMessage(msg,room_id) {
    rong.sendTextMessage({
        conversationType: 'CHATROOM', // PRIVATE 单聊，DISCUSSION 讨论组，GROUP 群组，CHATROOM 聊天室，SYSTEM 系统，CUSTOMER_SERVICE 客服
        targetId: room_id,
        text: msg,
        extra: {
            nickname:user.nickname,
            headimgurl:user.headimgurl,
            customer_id:user.customer_id
        }
    }, function(ret, err) {
        //alert(JSON.stringify(ret));
    });
}

text是消息内容，extra是额外的内容，可以传用户昵称，头像等信息。

5.获取历史信息

// 获取聊天室历史信息
function getLatestChatRoomMessages(room_id) {
    rong.getLatestMessages({
        conversationType: 'CHATROOM',
        targetId: room_id,
        count: 20
    }, function(ret, err) {
        alert(JSON.stringify(ret));
    })
}

这几个方法，基本就够用了！

服务器端

<?php

/**
 * 融云聊天室相关接口
 */

class RongCloudAction extends ApiAction
{
    protected function _initialize()
    {
        parent::_initialize();
        include_once LIB_PATH . 'ORG/rongcloud/rongcloud.php';
    }

    // 查询在线状态
    public function checkOnline() {
        $appKey = 'xxx';
        $appSecret = 'xxx';

        $jsonPath = LIB_PATH . 'ORG/rongcloud/jsonsource/';
        $RongCloud = new RongCloud($appKey,$appSecret);

        $userId = $this->_post('userId','trim');
        if (empty($userId)) {
            $this->outData['status'] = 2;
            $this->outData['msg']    = "缺少参数userId";
            $this->printOut();
        }

        // 检查用户在线状态 方法
        $result = $RongCloud->user()->checkOnline($userId);
        exit($result);
    }

    // 创建聊天室
    public function createChatRoom() {
        $appKey = 'xxx';
        $appSecret = 'xxx';

        $jsonPath = LIB_PATH . 'ORG/rongcloud/jsonsource/';
        $RongCloud = new RongCloud($appKey,$appSecret);

        $roomId = $this->_post('roomId','trim');
        if (empty($roomId)) {
            $this->outData['status'] = 2;
            $this->outData['msg']    = "缺少参数roomId";
            $this->printOut();
        }

        $roomName = $this->_post('roomName','trim',$roomId."的直播");
        // 创建聊天室方法
        $chatRoomInfo[$roomId] = $roomName;
        $result = $RongCloud->chatroom()->create($chatRoomInfo);
        exit($result);
    }

    // 加入聊天室
    public function joinChatRoom() {
        $appKey = 'xxx';
        $appSecret = 'xxx';
     
        $jsonPath = LIB_PATH . 'ORG/rongcloud/jsonsource/';
        $RongCloud = new RongCloud($appKey,$appSecret);

        $userId = $this->_post('userId','trim');
        if (empty($userId)) {
            $this->outData['status'] = 2;
            $this->outData['msg']    = "缺少参数userId";
            $this->printOut();
        }

        $roomId = $this->_post('roomId','trim');
        if (empty($roomId)) {
            $this->outData['status'] = 2;
            $this->outData['msg']    = "缺少参数roomId";
            $this->printOut();
        }

        // 加入聊天室方法
        $result = $RongCloud->chatroom()->join([$userId], $roomId);
        exit($result);
    }

    // 查询聊天室信息
    public function queryChatRoom() {
        $appKey = 'xxx';
        $appSecret = 'xxx';

        $jsonPath = LIB_PATH . 'ORG/rongcloud/jsonsource/';
        $RongCloud = new RongCloud($appKey,$appSecret);

        $roomId = $this->_post('roomId','trim');
        if (empty($roomId)) {
            $this->outData['status'] = 2;
            $this->outData['msg']    = "缺少参数roomId";
            $this->printOut();
        }

        // 查询聊天室信息方法
        $result = $RongCloud->chatroom()->query([$roomId]);
        exit($result);
    }

    // 查询聊天室用户
    public function queryUserChatRoom() {
        $appKey = 'xxx';
        $appSecret = 'xxx';

        $jsonPath = LIB_PATH . 'ORG/rongcloud/jsonsource/';
        $RongCloud = new RongCloud($appKey,$appSecret);

        $roomId = $this->_post('roomId','trim');
        if (empty($roomId)) {
            $this->outData['status'] = 2;
            $this->outData['msg']    = "缺少参数roomId";
            $this->printOut();
        }

        // 查询聊天室内用户方法
        $result = $RongCloud->chatroom()->queryUser($roomId, '500', '2');
        exit($result);
    }

    // 销毁聊天室
    public function destroyChatRoom() {
        $appKey = 'xxx';
        $appSecret = 'xxx';

        $jsonPath = LIB_PATH . 'ORG/rongcloud/jsonsource/';
        $RongCloud = new RongCloud($appKey,$appSecret);

        $roomId = $this->_post('roomId','trim');
        if (empty($roomId)) {
            $this->outData['status'] = 2;
            $this->outData['msg']    = "缺少参数roomId";
            $this->printOut();
        }

        // 销毁聊天室方法
        $result = $RongCloud->chatroom()->destroy([$roomId]);
        exit($result);
    }

    // 发送聊天室信息
    public function publishChatroom() {
        $appKey = 'xxx';
        $appSecret = 'xxx';

        $jsonPath = LIB_PATH . 'ORG/rongcloud/jsonsource/';
        $RongCloud = new RongCloud($appKey,$appSecret);

        $userId = $this->_post('userId','trim');
        if (empty($userId)) {
            $this->outData['status'] = 2;
            $this->outData['msg']    = "缺少参数userId";
            $this->printOut();
        }

        $roomId = $this->_post('roomId','trim');
        if (empty($roomId)) {
            $this->outData['status'] = 2;
            $this->outData['msg']    = "缺少参数roomId";
            $this->printOut();
        }

        $content = $this->_post('content','trim');
        if (empty($content)) {
            $this->outData['status'] = 2;
            $this->outData['msg']    = "缺少参数content";
            $this->printOut();
        }

        $extra = $this->_post('extra','trim');

        // 发送聊天室消息方法（一个用户向聊天室发送消息，单条消息最大 128k。每秒钟限 100 次。）
        $result = $RongCloud->message()->publishChatroom($userId, [$roomId], 'RC:TxtMsg',"{\"content\":$content,\"extra\":$extra}");
        exit($result);
    }

}

这些接口可以辅助app端一起使用！

本文转自TBHacker博客园博客，原文链接：http://www.cnblogs.com/jiqing9006/p/6627516.html，如需转载请自行联系原作者