前言:因为我是业余的前端,所以在做融云web通信的时候遇到了很多问题,可能站在前端的角度,我解决的办法不是很完美,所以我希望如果有人看到了多给我一些提点 谢谢!
我不是标题党,我今天要说的就是基于融云的web开发简单的文字通信。 要了解一定php js java 页面之间的参数传递我是在php环境完成的 注册是在java 这种java和php之间的转换也是很简单的
如果要做到两个界面之间互发消息还能查询历史消息,就必须开通公有云专业版后,开启单群聊消息云存储。如果是自己娱乐我觉得没必要去开通,因为实在是太贵了(我做的时候用的是公司给的账号)。这个先跳过进入正题
一、注册融云的账号 (注册账号放在后台会比前端安全,如果放在前端注册,一些懂程序的会盗取你的appKey和appSecret)
/**
* 注册rongCloud账号
* @param agent
* string userModel.id 唯一标识,最大长度 30 个字符,建议使用 英文字母、数字 混排
* string userModel.name 名称,最大长度 60 个字符
* string userModel.portrait 合法的头像地址,最大长度 800 个字符
* @return
* "code": 200,
* "userId":
* "token":
*/
@PostMapping("/registerUser")
public void registerUser(Agent agent){
try {
PrintWriter out = response.getWriter();
//给jedis赋值
JedisTest.initJedis();
if(JedisTest.jedis.get(agent.getAgentId().toString()) != null) {
System.out.println("----------从缓存获取用户token信息"+agent.getAgentId());
String userInfo = JedisTest.jedis.get(agent.getAgentId().toString());
out.write(userInfo);
JedisTest.closeJedis();
return;
}
//appKey, appSecret自己注册融云后的账号
RongCloud rongCloud = RongCloud.getInstance(appKey, appSecret);
User User = rongCloud.user;
UserModel user = new UserModel()
.setId(agent.getAgentId().toString())
.setName(agent.getAgentName())
.setPortrait(agent.getAgentAvatar());
TokenResult result = User.register(user);
System.out.println("getToken: " + result.toString());
//存入到redis缓存
System.out.println("----------存放用户信息");
//setex设置缓存时间
JedisTest.jedis.setex(agent.getAgentId().toString(),72000,result.toString());
JedisTest.closeJedis();
out.write(result.toString());
}catch (Exception e){
System.out.println("注册rongCloud账号出错" + e.getMessage());
}
}
直接复制会有jedis报错,我的jediis代码就不贴出来了,因为我的jedis服务器搭建在linux系统一两句在这也说不清 你可以直接用自己的方式存放就好,缓存可以避免一直获取token
这是rongcloud mavenjar
<!--rongcloud通信jar包-->
<dependency>
<groupId>cn.rongcloud.im</groupId>
<artifactId>server-sdk-java</artifactId>
<version>3.0.1</version>
</dependency>
二、对融云方法的封装 (以下代码是我自己封装的js文件)
function RongCloud(){
}
RongCloud.prototype = {
constructor: RongCloud,
/**
* 初始化融云服务,并启动消息监听
* @param appkey app的唯一标识
*/
initRong: function (appkey) {
RongIMClient.init(appkey); //appkey
// 设置连接监听状态 ( status 标识当前连接状态)
// 连接状态监听器
RongIMClient.setConnectionStatusListener({
onChanged: function (status) {
switch (status) {
//链接成功
case RongIMLib.ConnectionStatus.CONNECTED:
console.log('链接成功');
break;
//正在链接
case RongIMLib.ConnectionStatus.CONNECTING:
console.log('正在链接');
break;
//重新链接
case RongIMLib.ConnectionStatus.DISCONNECTED:
console.log('断开连接');
break;
//其他设备登录
case RongIMLib.ConnectionStatus.KICKED_OFFLINE_BY_OTHER_CLIENT:
console.log('其他设备登录');
break;
//网络不可用
case RongIMLib.ConnectionStatus.NETWORK_UNAVAILABLE:
console.log('网络不可用');
break;
}
}
});
this.monitor();
},
/**
* 用户用token连接融云服务器
* @param token 用户的聊天token
*/
connectSession: function (callback,token) {
// 连接融云服务器。
RongIMClient.connect(token, {
onSuccess: function (userId) {
console.log("Login successfully." + userId);
callback && callback(true, userId);
},
onTokenIncorrect: function () {
console.log('token无效' + userId);
callback && callback(false, userId);
},
onError: function (errorCode) {
var info = '';
switch (errorCode) {
case RongIMLib.ErrorCode.TIMEOUT:
info = '超时';
break;
case RongIMLib.ErrorCode.UNKNOWN_ERROR:
info = '未知错误';
break;
case RongIMLib.ErrorCode.UNACCEPTABLE_PaROTOCOL_VERSION:
info = '不可接受的协议版本';
break;
case RongIMLib.ErrorCode.IDENTIFIER_REJECTED:
info = 'appkey不正确';
break;
case RongIMLib.ErrorCode.SERVER_UNAVAILABLE:
info = '服务器不可用';
break;
}
console.log(errorCode);
}
});
},
/**
* 消息监听
*/
monitor:function (){
// 消息监听器
RongIMClient.setOnReceiveMessageListener({
// 接收到的消息
onReceived: function (message) {
// 判断消息类型
switch (message.messageType) {
case RongIMClient.MessageType.TextMessage:
// 发送的消息内容将会被打印
console.log("message.content.content------" + JSON.stringify(message.content.content));
console.log('收到发送的消息');
if(typeof writeInContent != 'undefined'){ //在聊天页面才写入数据
writeInContent(1,message.content.content,message.senderUserId,'');//给接收者写入最新数据
}
break;
case RongIMClient.MessageType.VoiceMessage:
// 对声音进行预加载
// message.content.content 格式为 AMR 格式的 base64 码
RongIMLib.RongIMVoice.preLoaded(message.content.content);
break;
case RongIMClient.MessageType.ImageMessage:
// do something...
break;
case RongIMClient.MessageType.DiscussionNotificationMessage:
// do something...
break;
case RongIMClient.MessageType.LocationMessage:
// do something...
break;
case RongIMClient.MessageType.RichContentMessage:
// do something...
break;
case RongIMClient.MessageType.DiscussionNotificationMessage:
// do something...
break;
case RongIMClient.MessageType.InformationNotificationMessage:
// do something...
console.log('收到小灰条信息')
break;
case RongIMClient.MessageType.ContactNotificationMessage:
// do something...
break;
case RongIMClient.MessageType.ProfileNotificationMessage:
// do something...
break;
case RongIMClient.MessageType.CommandNotificationMessage:
// do something...
break;
case RongIMClient.MessageType.CommandMessage:
// do something...
break;
case RongIMClient.MessageType.UnknownMessage:
// do something...
break;
case RongIMClient.RegisterMessage.PersonMessage:
// do something...
break;
default:
// 自定义消息
// do something...
}
}
});
},
/**
* 获取会话列表
* @param callback 消息回调参数
* @return boolean 是否成功的状态码
* @return list 会话列表集合
*/
getSessionList: function (callback) {
RongIMClient.getInstance().getConversationList({
onSuccess: function(list) {
console.log("会话列表--"+ JSON.stringify(list))
callback && callback(true, list);
},
onError: function(error) {
// do something...r
result = "获取会话列表失败!"
callback && callback(false, result);
}
},null);
},
/**
* 获取指定的会话
* @param callback 消息回调参数
* @return boolean 是否成功的状态码
* @return list 会话列表集合
*/
getSessionListBytargetId: function(callback, targetId) {
var conversationType = RongIMLib.ConversationType.PRIVATE;
RongIMLib.RongIMClient.getInstance().getUnreadCount(conversationType,targetId,{
onSuccess:function(count){
// count => 指定会话的总未读数。
callback && callback(true, count);
},
onError:function(){
result = "获取会话列表失败!"
callback && callback(false, result);
}
});
},
/**
* 清空和莫个人的未读消息数
* @param callback 消息回调参数
* @param targetId 要清楚和谁的会话消息数
*/
cleanMessageCount: function (targetId) {
var conversationType = RongIMLib.ConversationType.PRIVATE;
RongIMClient.getInstance().clearUnreadCount(conversationType,targetId,{
onSuccess:function(){
console.log("清除未读消息数成功!");
},
onError:function(error){
console.log("清除未读消息数错误!"+ error);
}
});
},
/**
* 获取自己和莫个人的聊天记录
* @param callback 消息回调参数
* @param conversationType 私聊,其他会话选择相应的消息类型即可。
* @param targetId 想获取自己和谁的历史消息,targetId 赋值为对方的 Id。
* @param timestrap 默认传 null,若从头开始获取历史消息,请赋值为 0 ,timestrap = 0;
* @param count 每次获取的历史消息条数,范围 0-20 条,可以多次获取。
* @return list 聊天数据集合
* @return hasMag 是否还有历史记录 有位true
*/
getHistoryById: function (callback,conversationType,targetId,timestrap,count) {
RongIMLib.RongIMClient.getInstance().getHistoryMessages(conversationType, targetId, timestrap, count, {
onSuccess: function(list, hasMsg) {
// list => Message 数组。
// hasMsg => 是否还有历史消息可以获取。
// console.log("targetId------" + targetId);
// console.log("GetHistoryMessages:list" + JSON.stringify(list));
callback && callback(hasMsg, list);
},
onError: function(error) {
console.log("获取历史" , error);
callback && callback(false, error);
}
});
},
sendMessage :function(targetId,content,extra) {
var msg = new RongIMLib.TextMessage({content:content,extra:extra});
var conversationtype = RongIMLib.ConversationType.PRIVATE; // 单聊,其他会话选择相应的消息类型即可。
var targetId = targetId; // 目标 Id
RongIMClient.getInstance().sendMessage(conversationtype, targetId, msg, {
onSuccess: function (message) {
//message 为发送的消息对象并且包含服务器返回的消息唯一Id和发送消息时间戳
console.log("Send successfully");
},
onError: function (errorCode,message) {
var info = '';
switch (errorCode) {
case RongIMLib.ErrorCode.TIMEOUT:
info = '超时';
break;
case RongIMLib.ErrorCode.UNKNOWN_ERROR:
info = '未知错误';
break;
case RongIMLib.ErrorCode.REJECTED_BY_BLACKLIST:
info = '在黑名单中,无法向对方发送消息';
break;
case RongIMLib.ErrorCode.NOT_IN_DISCUSSION:
info = '不在讨论组中';
break;
case RongIMLib.ErrorCode.NOT_IN_GROUP:
info = '不在群组中';
break;
case RongIMLib.ErrorCode.NOT_IN_CHATROOM:
info = '不在聊天室中';
break;
default :
info = x;
break;
}
console.log('发送失败:' + info);
}
}
);
}
}
代码太多不过要解释的只有一个地方:
在消息监听的那个方法中我做了一个if判断如果当前在聊天页面,那么我就把收到的消息写入到聊天页面。
其实走到这一步就得靠自己的逻辑去完成了
要聊天首先得要有两个页面 会话页面 和 消息页面因为是web端的所以每个页面都得调用初始化融云服务和登录融云 (具体实现方法“参照”三四)三四只能参照
1.用注册的账号去发送消息给另一个账号产生一个会话(相当于qq的加好友) 发送消息的是注册融云的id(是自己手动输入的注册融云的那个值)
三、会话页面(这个我是在php的环境下完成的)
<!DOCTYPE html>
<head>
<meta charset="utf-8" />
<title>会话</title>
<meta content="text/html; charset=utf-8" http-equiv="Content-Type" />
<meta content="width=device-width, initial-scale=1.0, minimum-scale=1.0, maximum-scale=1.0, user-scalable=no" name="viewport">
<!-- Mobile Devices Support @begin -->
<meta content="application/xhtml+xml;charset=UTF-8" http-equiv="Content-Type">
<meta content="telephone=no, address=no" name="format-detection">
<meta name="apple-mobile-web-app-capable" content="yes" />
<!-- apple devices fullscreen -->
<meta name="apple-mobile-web-app-status-bar-style" content="black-translucent" />
<head>
<style>
*{
padding: 0px;
margin: 0px;
outline: 0;
list-style:none;
box-sizing: border-box;
-moz-box-sizing: border-box; /* Firefox */
-webkit-box-sizing: border-box; /* Safari */
}
#main{
width: 100%;
height: 100%;
}
.sessionData{
width: 100%;
height: 70px;
border-bottom: 1px #999999 solid;
}
.imgDiv{
float:left; width: 50px;
height: 50px;
margin-left:30px;
margin-top:10px;
border-radius: 100%;
-moz-border-radius: 100%;
-webkit-border-radius: 100%;
border:solid 2px #FFFFFF;
}
.nameAndMessage{
float:left;
width: 50%;
height: 50px;
margin-left:10px;
margin-top:10px;
font-size: 12px
}
.agentName{
margin: 0;
padding: 0;
height: 25px;
width: 50%;
line-height: 28px;
overflow:hidden
}
.message{
margin: 0;
padding: 0;
height: 25px;
width: 50%;
line-height: 22px;
overflow:hidden
}
.date{
float:right;
margin: 0;
margin-left: 20px;
padding: 0;
height: 70px;
width: 50px;
line-height: 70px;
font-size: 12px
}
.count{
float:right;
margin-top: 25px;
margin-right: 20px;
height: 20px;
width: 20px;
line-height: 20px;
text-align: center;
font-size: 12px;
background: red;
color: #FFFFFF;
border-radius: 100%;
-moz-border-radius: 100%;
-webkit-border-radius: 100%;
}
/*加载数据时隐藏源代码*/
[v-cloak] {
display: none;
}
a {
text-decoration:none;
out-line: none;
color: #000000;
}
</style>
</head>
<body>
<div id="main">
<div id="sessionMain">
<div class="sessionData" v-for="(item, index) in items" v-cloak>
<div class="imgDiv">
<img :src="userInfo[index].headImgUrl" width="50px" height="50px"/>
</div>
<a :href="'<?php echo base_url()?>mobile/wx_chat/messagePage?targetId='+item.targetId+'&count='+item.unreadMessageCount">
<div class="nameAndMessage">
<div class="agentName">
{{ userInfo[index].nickName }}
</div>
<div class="message">
{{ item.latestMessage.content.content }}
</div>
</div>
</a>
<div v-if="item.unreadMessageCount === 0">
<div class="date">
{{ dataStr[index] }}
</div>
</div>
<div v-else>
<div class="count">
{{ item.unreadMessageCount }}
</div>
</div>
</div>
</div>
</div>
</body>
</html>
<script type="text/javascript" src="/js/chat/dataUtil.js" ></script>
<script type="text/javascript" src="/js/chat/rongCloud.js" ></script>
<script type="text/javascript" src="/js/chat/rongConfig.js" ></script>
<script type="text/javascript" src="/js/jquery-1.7.2.min.js"></script>
<script type="text/javascript" src="/js/vue.min.js"></script>
<script src="https://cdn.ronghub.com/RongIMLib-2.2.5.min.js"></script>
<script type="text/javascript">
//定义缓存对象
window.onload = initRong();
var rongCloud = new RongCloud();
var dateGS = new DateGS();
//定义缓存对象
var userCache = {};
/**
* 初始化融云服务,并启动消息监听
*/
function initRong(){
var rongCloud = new RongCloud();
var rongConfig = new RongConfig();
rongCloud.initRong(rongConfig.getAppkey());
//用户登录rong
loginRong();
}
/**
* 登录融云
*/
function loginRong() {
var rongCloud = new RongCloud();
//获取用户token
var token = "<?php echo $imToken ?>";
rongCloud.connectSession(function(status,userId){
if(status) {
//把自己的token和userId存放到缓存
$.data(userCache, 'token', token);
$.data(userCache, 'userId', userId);
//获取会话
getSessionList();
}else {
alert("登录失败!");
}
},token);
}
/**
* 获取会话列表
*/
function getSessionList() {
if(localStorage.getItem("closeId") != null) {
closeMessageCount();
}
rongCloud.getSessionList(function (status, list) {
if(status) {
var targetIds = '';
for(var i in list){
targetIds += list[i].targetId+",";
}
targetIds = targetIds.substr(0,targetIds.length-1);
//先用加姓名头像 25 24 用户的
//targetIds = "oHNCGjmOMyk87ACKZrZ_A1CEiagA,oHNCGjrgAym1xXiAWsPJfXPChTk4";
// 获取用户信息
$.ajax({
type: "get",
url: "/api/mobile/agentService/getUserInfoByOpenId",
dataType: "text",
data: {openIds:targetIds},
success: function(ret, err) {
var dataStr = [];
for(var i in list) {
dataStr.push(dateGS.getLocalTime(list[i].sentTime));
}
//用户信息
ret = $.parseJSON(ret);
console.log(JSON.stringify(ret))
if(ret.resultCode == 1) {
//vue渲染数据到页面
var sessionMain = new Vue({
el: '#sessionMain',
data: {
token: $.data(userCache, 'token'),
items: list, //融云放回的数据
dataStr: dataStr, //格式化后的消息发送时间
userInfo: ret.extend, //用户的集合
},
})
} else {
alert("获取用户信息失败!");
}
},
error:function(){
$('#content_empty').show();
}
});
}
});
}
/**
* 清空消息数 要清空必须得
* 在这个页面获取一下历史消息才能永久成功
*/
function closeMessageCount() {
//缓存有数据就是有清空的数据
if(localStorage.getItem("closeId") != null) {
rongCloud.getHistoryById(function (hasMag, list) {
//清空数据
rongCloud.cleanMessageCount(localStorage.getItem("closeId"));
localStorage.removeItem("closeId");
},RongIMLib.ConversationType.PRIVATE,localStorage.getItem("closeId"), null, 20);
}
}
</script>
解释一下吧会话页面是通过php控制器跳转的,没有任何的参数。
appkey我也是封装到js里面的因为一些隐私问题我不能把这个js提供出来,你如果注册了融云那么就直接把appkey替换就行
在页面中我用一个ajax去注册融云用户得到返回的token再登录融云,然后再查询会话列表,有些图像用户名称的我是查询的表数据,所以这一步是不能复制粘贴的
四、消息页面 (这个我是在php的环境下完成的)
<!DOCTYPE html>
<head>
<meta charset="utf-8" />
<!-- 移动设备支持 -->
<meta http-equiv="X-UA-Compatible" content="IE=edge,chrome=1"/>
<meta name="viewport" content="width=device-width, initial-scale=1, maximum-scale=1"/>
<meta name="apple-mobile-web-app-capable" content="yes"/>
<meta name="apple-mobile-web-app-status-bar-style" content="black"/>
</head>
<style>
/**重置标签默认样式*/
* {
margin: 0;
padding: 0;
list-style: none;
font-family: '微软雅黑'
}
#container {
width: 100%;
height: 100%;
background: #eee;
position: relative;
}
.header {
width: 100%;
height: 50px;
color: #fff;
background: #999999;
line-height: 50px;
font-size: 20px;
position: fixed;
padding: 0 100px 0px 0px;
top: 0px;
}
.footer {
width: 100%;
height: 50px;
background: #999999;
position: fixed;
bottom: 0;
padding-top: 10px;
padding-bottom: 10px;
}
.footer input {
width: 75%;
height: 45px;
outline: none;
font-size: 20px;
text-indent: 10px;
position: absolute;
border-radius: 6px;
left:3%;
}
.footer span {
display: inline-block;
width: 15%;
height: 48px;
background: #ccc;
font-weight: 900;
line-height: 45px;
cursor: pointer;
text-align: center;
position: absolute;
right: 3%;
border-radius: 6px;
}
.content {
font-size: 20px;
width: 100%;
overflow: auto;
margin-top:50px;
margin-bottom: 70px;
}
.content li {
margin-top: 10px;
width: 100%;
display: block;
clear: both;
overflow: hidden;
}
.content li span{
background: #7cfc00;
padding: 10px;
border-radius: 10px;
margin: 6px 10px 0 10px;
max-width: 310px;
border: 1px solid #ccc;
box-shadow: 0 0 3px #ccc;
}
.imgleft {
float: left;
margin-left: 5px;
}
.imgright {
float: right;
margin-right: 5px;
}
.spanleft{
float: left;
background: #fff;
}
.spanright {
float: right;
background: #7cfc00;
}
/*加载数据时隐藏源代码*/
[v-cloak] {
display: none;
}
</style>
<html>
<body>
<div id="container">
<div class="header">
<span onclick="jump()" style="float:left;width: 12%"><img src="/image/left.png" style="height: 50px;"/></span>
<div id="targetId" style="float:left;text-align: center;line-height: 50px;width: 76%;" v-cloak>{{ targetName }}</div>
<div style="float:left;width: 12%;height: 50px;"></div>
</div>
<ul class="content">
<li style=""></li>
</ul>
<div class="footer">
<input id="text" type="text" placeholder="说点什么吧...">
<span id="btn">发送</span>
</div>
</div>
</body>
</html>
<script type="text/javascript" src="/js/chat/dataUtil.js" ></script>
<script type="text/javascript" src="/js/chat/rongCloud.js" ></script>
<script type="text/javascript" src="/js/chat/rongConfig.js" ></script>
<script type="text/javascript" src="/js/jquery-1.7.2.min.js"></script>
<script type="text/javascript" src="/js/vue.min.js"></script>
<script src="https://cdn.ronghub.com/RongIMLib-2.2.5.min.js"></script>
<script type="text/javascript">
window.onload = initRong();
var rongCloud = new RongCloud();
//初始化融云服务,并启动消息监听
function initRong(){
var rongCloud = new RongCloud();
var rongConfig = new RongConfig();
rongCloud.initRong(rongConfig.getAppkey());
//用户登录rong
loginRong();
getUserInfo();
//初始化页面
pageInit();
//把要清空的对象id存放到缓存
localStorage.setItem("closeId","<?php echo $targetId ?>");
}
/**
* 把用户头像姓名存放到缓存
*/
function getUserInfo() {
//获取对方的id和自己的id
var targetIdAndSendId = localStorage.getItem("userId") + "," + "<?php echo $targetId?>";
//先用加姓名头像 25 24 用户的 25 是自己的id 24使目标id
//var targetIdAndSendId = "oHNCGjmOMyk87ACKZrZ_A1CEiagA,oHNCGjrgAym1xXiAWsPJfXPChTk4";
// 获取用户信息
$.ajax({
type: "get",
url: "/api/mobile/agentService/getUserInfoByOpenId",
dataType: "text",
data: {openIds:targetIdAndSendId},
success: function(ret, err) {
//用户信息
ret = $.parseJSON(ret);
if(ret.resultCode == 1) {
//vue渲染数据到页面
var header = new Vue({
el: '.header',
data: {
targetName: ret.extend[1].nickName,
},
})
//把用户头像存放到缓存
localStorage.setItem("userImgUrl", ret.extend[0].headImgUrl);
localStorage.setItem("targetImgUrl",ret.extend[1].headImgUrl);
} else {
alert("获取用户头像失败!");
}
},
error:function(){
$('#content_empty').show();
}
});
}
/**
* 登录时获取历史消息
*/
function loginRong() {
//获取用户token
var token = "<?php echo $token ?>";
var rongCloud = new RongCloud();
rongCloud.connectSession(function(status,userId){
if(status) {
//把自己的token和userId存放到缓存
localStorage.setItem("token", token);
localStorage.setItem("userId",userId);
//初始化时获取用户历史消息3-10条
var targetIdPar = "<?php echo $targetId ?>";
var countPar = "<?php echo $count ?>";
getHistory(targetIdPar,parseInt(countPar),0);
}else {
alert("登录失败!");
}
},token);
}
/**
* 初始化融云 和 页面数据渲染
*/
//定义自己的头像地址 和 别人的头像存放
function pageInit(){
var userInfo = {};
var btn = document.getElementById('btn');
var text = document.getElementById('text');
var content = document.getElementsByTagName('ul')[0];
//一定要设置高度才能把数据实时的放在最下面 高度为屏幕分辨率的高减去上下div的高度 上50px 下70px
//还要减去减去初始化3条信息的高度150 网页才能兼容 ix下面会多出一部分不兼容
content.style.height=window.screen.height-120+"px";
btn.onclick = function(){
if(text.value.replace(/\s+/g,"") == '') {
alert("不能发送空白消息");
text.value = '';
return;
}else {
writeInContent(0,text.value,"<?php echo $targetId?>",'');
// 内容过多时,将滚动条放置到最底端
content.scrollTop = content.scrollHeight;
//sendGroupChat(text.value);
sendMessage("<?php echo $targetId?>", text.value);
text.value = '';
}
}
}
/**
* 写入数据到content
* writeFormat 写入在左还是右 0右 1左
* contentText 写入内容
* list 为空表示是单条插入到最底部,为集合表示多条插入到最顶部
*/
function writeInContent(num,contentText,closeId,list) {
var content = document.getElementsByTagName('ul')[0];
var str = '';
for(var i in list) {
//如果发送人时自己那么就显示到右边
if (list[i].senderUserId == localStorage.getItem("userId")) {
str += '<li><img class="imgright" src="'+localStorage.getItem('userImgUrl')+'" width="50px" height="50px"><span class="spanright">'+list[i].content.content+'</span></li>';
} else {
str += '<li><img class="imgleft" src="'+localStorage.getItem('targetImgUrl')+'" width="50px" height="50px"><span class="spanleft">'+list[i].content.content+'</span></li>';
}
}
if(list == '') {
if(num==0){
str = '<li><img class="imgright" src="'+localStorage.getItem("userImgUrl")+'" width="50px" height="50px"><span class="spanright">'+contentText+'</span></li>';
}else {
str = '<li><img class="imgleft" src="'+localStorage.getItem("targetImgUrl")+'" width="50px" height="50px"><span class="spanleft">'+contentText+'</span></li>';
}
content.innerHTML += str;
}else {
$(content).prepend(str);
}
}
//var xfjApiUrl = '<?php echo WX_XFJ_API_URL ?>';
function sendMessage(targetId,contentText) {
rongCloud.sendMessage(targetId,contentText,"");
/*//发送消息
var agentId = localStorage.getItem("userId");
agentId = agentId+"";
targetId = targetId+"";
$.ajax({
type: "post"
,url:xfjApiUrl+"/mobile/wx_chat/publishMessage"
//,url:"http://192.168.10.181:9091/api/mobile/chatService/publishMessage"
,data: {fromUserId:agentId,toUserId:targetId,content:contentText}
,datatype:'text'
,success:function(data){
//发送成功后...
}
,timeout:20000
})*/
}
/**
* 获取和莫个人的聊天记录 并调用写入数据到congten得方法
* @param targetIdPar 和谁的记录
* @param countPar 查询几条
* @param mode 方式 1 为点击加载更多 0为初始化查询
* @return hasMag 真表示还有数据
*/
function getHistory(targetIdPar,countPar,mode){
if (mode == 1) { //点击获取历史消息的时候删除一下加载更多这几个字
$(".jzgd").empty();
}
var rongCloud = new RongCloud();
var conversationType = RongIMLib.ConversationType.PRIVATE; //私聊,其他会话选择相应的消息类型即可。
var targetId= targetIdPar+""; // 想获取自己和谁的历史消息,targetId 赋值为对方的 Id。 字符串类型
var timestrap = null; // 默认传 null,若从头开始获取历史消息,请赋值为 0 ,timestrap = 0; int
var count = parseInt(countPar); // 每次获取的历史消息条数,范围 0-20 条,可以多次获取。 int性
if(1 >= count){ //小于等于1报错 仿qq0的时候查3条
count = 3;
}
if(count >= 20) { //超过二十报错 那么就不让他超过20条
count = 20;
}
rongCloud.getHistoryById(function (hasMag, list) {
writeInContent('','',"<?php echo $targetId ?>",list);
if(parseInt(countPar) != 4 ) { //第一次获取的历史消息数和传过来的未读消息数相同是hasMag还是为true
}
if(hasMag){
var rowsDisplayed = 10; //查询历史消息每次多加载十条数据
//加载更多 //onclick=\"getHistory("+targetIdPar+","+null+","+20+")\"
targetIdPar = "'"+targetIdPar+"'";
var jzgd = "<li class='jzgd' onclick=\"getHistory("+targetIdPar+","+rowsDisplayed+","+1+")\" style='text-align: center;font-size: 16px;color:#4EA9E9'>查看更多消息</li>";
$(".content").prepend(jzgd);
}
},conversationType,targetId, timestrap, count);
}
/**
* 清空消息数 要清空必须得
* 在这个页面获取一下历史消息才能永久成功
*/
function closeMessageCount(closeId) {
var rongCloud = new RongCloud();
rongCloud.getHistoryById(function (hasMag, list) {
//清空数据
rongCloud.cleanMessageCount(localStorage.getItem("closeId"));
},RongIMLib.ConversationType.PRIVATE,localStorage.getItem("closeId"), null, 20);
}
/**
* 跳转到会话页面
*/
function jump(){
window.location.href = "/mobile/wx_chat/conversationPage";
}
</script>
解释一下
1.封装的融云js文件中有个地方依赖这个页面(就是之前提到的监听消息的那段) 如果监听到有消息那么就调用这个页面的写入方法----writeInContent
2.?targetId=971b90fa-bcce-48bb-864c-79c784889e1d&count=0 通过控制器跳转的时候要传两个参数一 targetId:你要查询你和谁的聊天 count:第一次你要查询几条消息
会话页面和聊天页面只能作为参照
复制无效!
希望能帮到你,或者你能帮到我!