发送和接收消息
发送和接收消息
登录环信即时通讯后,用户可以在单聊、群聊、聊天室中发送如下类型的消息:
- 文字消息,包含超链接和表情;
- 附件消息,包含图片、语音、视频及文件消息;
- 位置消息;
- 透传消息;
- 自定义消息;
- 合并消息;
- 定向消息。
对于单聊,环信即时通信 IM 默认支持陌生人之间发送消息,即无需添加好友即可聊天。若仅允许好友之间发送单聊消息,你需要你需要开启好友关系检查。对于群组和聊天室,用户每次只能向所属的单个群组和聊天室发送消息。
提示
对于聊天室消息,环信即时通讯提供消息分级功能,将消息的优先级划分为高、普通和低三种级别,高优先级的消息会优先送达。你可以在创建消息时对指定聊天室消息类型或指定成员的消息设置为高优先级,确保这些消息优先送达。这种方式确保在聊天室内消息并发量很大或消息发送频率过高时,重要消息能够优先送达,从而提升重要消息的可靠性。 当服务器的负载较高时,会优先丢弃低优先级的消息,将资源留给高优先级的消息。不过,消息分级功能只确保消息优先到达,并不保证必达。服务器负载过高的情况下,即使是高优先级消息依然会被丢弃。
本文介绍如何使用即时通讯 IM Web SDK 实现发送和接收这些类型的消息。
技术原理
环信即时通讯 IM Web SDK 可以实现消息的发送和接收。
发送和接收消息:
- 消息发送方调用
create
方法创建文本、文件或附件消息。 - 消息发送方调用
send
方法发送消息。 - 消息接收方调用
addEventHandler
监听消息事件,并在相应回调中接收消息。
消息收发流程如下:
- 用户 A 发送一条消息到环信的消息服务器。
- 单聊时消息服务器发消息给用户 B,群聊时发消息给群内其他每个成员。
- 用户收到消息。
前提条件
开始前,请确保满足以下条件:
实现方法
发送文本消息
使用 Message
类创建并发送文本消息。示例代码如下:
默认情况下,SDK 对单个用户发送消息的频率未做限制。如果你联系了环信商务设置了该限制,一旦在单聊、群聊或聊天室中单个用户的消息发送频率超过设定的上限,SDK 会上报错误,即错误码 509 MESSAGE_CURRENT_LIMITING
。
// 发送文本消息。
function sendTextMessage() {
let option = {
// 消息类型。
type: "txt",
// 消息内容。
msg: "message content",
// 消息接收方:单聊为对方用户 ID,群聊和聊天室分别为群组 ID 和聊天室 ID。
to: "username",
// 会话类型:单聊、群聊和聊天室分别为 `singleChat`、`groupChat` 和 `chatRoom`,默认为单聊。
chatType: "singleChat",
};
// 创建文本消息。
let msg = WebIM.message.create(option);
// 调用 `send` 方法发送该文本消息。
conn.send(msg).then((res)=>{
console.log("Send message success",res);
}).catch((e)=>{
console.log("Send message fail",e);
});
}
对于聊天室消息,可设置消息优先级。示例代码如下:
// 发送文本消息。
function sendTextMessage() {
let option = {
type: "txt",
msg: "message content",
// 聊天室消息的优先级。如果不设置,默认值为 `normal`,即“普通”优先级。
priority: "high"
to: "chat room ID",
chatType: "chatRoom",
};
let msg = WebIM.message.create(option);
conn.send(msg).then(()=>{
console.log("Send message success");
}).catch((e)=>{
console.log("Send message fail");
});
}
若初始化时打开了 useReplacedMessageContents
开关,发送文本消息时如果被内容审核(Moderation)进行了内容替换,发送方会收到替换后的内容。若该开关为关闭状态,则发送方不会收到替换后的内容。
接收消息
你可以通过 addEventHandler
注册监听器监听消息事件。你可以添加多个事件。当不再监听事件时,请确保删除监听器。
当消息到达时,接收方会收到 onXXXMessage
回调。每个回调包含一条或多条消息。你可以遍历消息列表,并可以解析和展示回调中的消息。
对于聊天室消息,你可以通过消息的 broadcast
属性判断该消息是否为通过 REST API 发送的聊天室全局广播消息。
// 使用 `addEventHandler` 监听回调事件
conn.addEventHandler("eventName", {
// SDK 与环信服务器连接成功。
onConnected: function (message) {},
// SDK 与环信服务器断开连接。
onDisconnected: function (message) {},
// 当前用户收到文本消息。
onTextMessage: function (message) {},
// 当前用户收到图片消息。
onImageMessage: function (message) {},
// 当前用户收到透传消息。
onCmdMessage: function (message) {},
// 当前用户收到语音消息。
onAudioMessage: function (message) {},
// 当前用户收到位置消息。
onLocationMessage: function (message) {},
// 当前用户收到文件消息。
onFileMessage: function (message) {},
// 当前用户收到自定义消息。
onCustomMessage: function (message) {},
// 当前用户收到视频消息。
onVideoMessage: function (message) {},
// 当前用户订阅的其他用户的在线状态更新。
onPresence: function (message) {},
// 当前用户收到好友邀请。
onContactInvited: function (msg) {},
// 联系人被删除。
onContactDeleted: function (msg) {},
// 新增联系人。
onContactAdded: function (msg) {},
// 当前用户发送的好友请求被拒绝。
onContactRefuse: function (msg) {},
// 当前用户发送的好友请求被同意。
onContactAgreed: function (msg) {},
// 当前用户收到群组邀请。
onGroupEvent: function (message) {},
// 本机网络连接成功。
onOnline: function () {},
// 本机网络掉线。
onOffline: function () {},
// 调用过程中出现错误。
onError: function (message) {},
// 当前用户收到的消息被消息发送方撤回。
onRecallMessage: function (message) {},
// 当前用户发送的消息被接收方收到。
onReceivedMessage: function (message) {},
// 当前用户收到消息送达回执。
onDeliveredMessage: function (message) {},
// 当前用户收到消息已读回执。
onReadMessage: function (message) {},
// 当前用户收到会话已读回执。
onChannelMessage: function (message) {},
});
发送附件消息
语音、图片、视频和文件消息本质上是附件消息。发送和接收附件消息的流程如下:
- 创建和发送附件类型消息。SDK 将附件上传到环信服务器,获取消息的基本信息以及服务器上附件文件的路径。
对于图片消息来说,环信服务器会自动生成图片缩略图;而对于视频消息来说,视频的首帧为缩略图。
- 接收附件消息。
接收方可以自行下载语音、图片、图片缩略图、视频和文件。
对于消息附件,你也可以将附件上传到自己的服务器,而不是环信服务器,然后发送消息。这种情况下,需要在 SDK 初始化时将 Connection
类中的 useOwnUploadFun
参数设置为 true
。例如,对于图片消息,上传附件后,调用 sendPrivateUrlImg
方法传入图片的 URL 发送图片消息。
function sendPrivateUrlImg() {
let option = {
chatType: "singleChat",
// 消息类型。
type: "img",
// 图片文件的 URL 地址。
url: "img url",
// 消息接收方:单聊为对方用户 ID,群聊和聊天室分别为群组 ID 和聊天室 ID。
to: "username",
};
// 创建一条图片消息。
let msg = WebIM.message.create(option);
// 调用 `send` 方法发送该图片消息。
conn.send(msg);
}
发送和接收语音消息
发送语音消息前,你应该在 app 级别实现录音,提供录制的语音文件的 URI 和时长。
参考以下代码示例创建和发送语音消息:
function sendPrivateAudio() {
// 获取语音文件。
let input = document.getElementById("audio");
let file = WebIM.message.getFileUrl(input);
let allowType = {
mp3: true,
amr: true,
wmv: true,
};
if (file.filetype.toLowerCase() in allowType) {
let option = {
// 消息类型。
type: "audio",
file: file,
// 语音文件长度,单位为秒。
length: "3",
// 消息接收方:单聊为对方用户 ID,群聊和聊天室分别为群组 ID 和聊天室 ID。
to: "username",
// 会话类型:单聊、群聊和聊天室分别为 `singleChat`、`groupChat` 和 `chatRoom`。
chatType: "singleChat",
// 语音文件上传失败。
onFileUploadError: function () {
console.log("onFileUploadError");
},
// 语音文件上传进度。
onFileUploadProgress: function (e) {
console.log(e);
},
// 语音文件上传成功。
onFileUploadComplete: function () {
console.log("onFileUploadComplete");
},
ext: { },
};
// 创建一条语音消息。
let msg = WebIM.message.create(option);
// 调用 `send` 方法发送该语音消息。
conn
.send(msg)
.then((res) => {
// 语音文件成功发送。
console.log("Success");
})
.catch((e) => {
// 语音文件发送失败。
console.log("Fail");
});
}
}
接收方收到 onAudioMessage
回调,根据消息 url
字段获取语音文件的服务器地址,从而获取语音文件。
// 使用 `addEventHandler` 监听回调事件
conn.addEventHandler("eventName", {
// 当前用户收到语音消息。
onAudioMessage: function (message) {
// 语音文件在服务器的地址。
console.log(message.url);
},
});
发送和接收图片消息
对于图片消息,服务器会根据用户设置的 thumbnailHeight
和 thumbnailWidth
参数自动生成图片的缩略图。若这两个参数未传,则图片的高度和宽度均默认为 170 像素。你也可以在 环信即时通讯控制台的 服务概览
页面的 设置
区域修改该默认值。
请参考以下代码示例创建和发送图片消息:
function sendPrivateImg() {
// 选择本地图片文件。
let input = document.getElementById("image");
let file = WebIM.message.getFileUrl(input);
let allowType = {
jpg: true,
gif: true,
png: true,
bmp: true,
};
if (file.filetype.toLowerCase() in allowType) {
let option = {
// 消息类型。
type: "img",
file: file,
ext: {
// 图片文件长度,单位为字节。
file_length: file.data.size,
},
// 消息接收方:单聊为对方用户 ID,群聊和聊天室分别为群组 ID 和聊天室 ID。
to: "username",
// 会话类型:单聊、群聊和聊天室分别为 `singleChat`、`groupChat` 和 `chatRoom`。
chatType: "singleChat",
// 图片文件上传失败。
onFileUploadError: function () {
console.log("onFileUploadError");
},
// 图片文件上传进度。
onFileUploadProgress: function (e) {
console.log(e);
},
// 图片文件上传成功。
onFileUploadComplete: function () {
console.log("onFileUploadComplete");
},
thumbnailHeight: 200,
thumbnailWidth: 200,
};
// 创建一条图片消息。
let msg = WebIM.message.create(option);
// 调用 `send` 方法发送该图片消息。
conn
.send(msg)
.then((res) => {
// 图片文件成功发送。
console.log("Success");
})
.catch((e) => {
// 图片文件发送失败。
console.log("Fail");
});
}
}
接收方收到 onImageMessage
回调,根据消息 url
字段获取图片文件的服务器地址,从而获取图片文件。
// 使用 `addEventHandler` 监听回调事件
conn.addEventHandler("eventName", {
// 当前用户收到图片消息。
onImageMessage: function (message) {
// 图片文件在服务器的地址。
console.log(message.url);
// 图片缩略图文件在服务器的地址。
console.log(message.thumb);
},
});
发送和接收视频消息
在发送视频消息之前,应在 app 级别实现视频捕获,获得捕获的视频文件的时长,单位为秒。
参考以下代码示例创建和发送视频消息:
function sendPrivateVideo() {
// 选择本地视频文件。
let input = document.getElementById("video");
let file = WebIM.message.getFileUrl(input);
let allowType = {
mp4: true,
wmv: true,
avi: true,
rmvb: true,
mkv: true,
};
if (file.filetype.toLowerCase() in allowType) {
let option = {
// 消息类型。
type: "video",
file: file,
// 消息接收方:单聊为对方用户 ID,群聊和聊天室分别为群组 ID 和聊天室 ID。
to: "username",
// 会话类型:单聊、群聊和聊天室分别为 `singleChat`、`groupChat` 和 `chatRoom`。
chatType: "singleChat",
onFileUploadError: function () {
// 视频文件上传失败。
console.log("onFileUploadError");
},
onFileUploadProgress: function (e) {
// 视频文件上传进度。
console.log(e);
},
onFileUploadComplete: function () {
// 视频文件上传成功。
console.log("onFileUploadComplete");
},
ext: { },
};
// 创建一条视频消息。
let msg = WebIM.message.create(option);
// 调用 `send` 方法发送该视频消息。
conn
.send(msg)
.then((res) => {
// 视频文件成功发送。
console.log("Success");
})
.catch((e) => {
// 视频文件发送失败。例如,本地用户被禁言或封禁。
console.log("Fail");
});
}
}
接收方收到 onVideoMessage
回调,根据消息 url
字段获取视频文件的服务器地址,从而获取视频文件。
// 使用 `addEventHandler` 监听回调事件
conn.addEventHandler("eventName", {
// 当前用户收到视频消息。
onVideoMessage: function (message) {
// 视频文件在服务器的地址。
console.log(message.url);
// 视频首帧缩略图文件在服务器的地址。
console.log(message.thumb);
},
});
发送和接收文件消息
参考以下代码示例创建、发送和接收文件消息:
function sendPrivateFile() {
// 选择本地文件。
let input = document.getElementById("file");
let file = WebIM.message.getFileUrl(input);
let allowType = {
jpg: true,
gif: true,
png: true,
bmp: true,
zip: true,
txt: true,
doc: true,
pdf: true,
};
if (file.filetype.toLowerCase() in allowType) {
let option = {
// 消息类型。
type: "file",
file: file,
// 消息接收方:单聊为对方用户 ID,群聊和聊天室分别为群组 ID 和聊天室 ID。
to: "username",
// 会话类型:单聊、群聊和聊天室分别为 `singleChat`、`groupChat` 和 `chatRoom`。
chatType: "singleChat",
// 文件上传失败。
onFileUploadError: function () {
console.log("onFileUploadError");
},
// 文件上传进度。
onFileUploadProgress: function (e) {
console.log(e);
},
// 文件上传成功。
onFileUploadComplete: function () {
console.log("onFileUploadComplete");
},
ext: { },
};
// 创建一条文件消息。
let msg = WebIM.message.create(option);
// 调用 `send` 方法发送该文件消息。
conn
.send(msg)
.then((res) => {
// 文件消息成功发送。
console.log("Success");
})
.catch((e) => {
// 文件消息发送失败。
console.log("Fail");
});
}
}
接收方收到 onFileMessage
回调,根据消息 url
字段获取文件的服务器地址,从而获取文件。
// 使用 `addEventHandler` 监听回调事件
conn.addEventHandler("eventName", {
// 当前用户收到文件消息。
onFileMessage: function (message) {
// 文件在服务器的地址。
console.log(message.url);
},
});
发送位置消息
当你需要发送位置时,需要集成第三方的地图服务,获取到位置点的经纬度信息。接收方接收到位置消息时,需要将该位置的经纬度,借由第三方的地图服务,将位置在地图上显示出来。
const sendLocMsg = () => {
let coords;
if (navigator.geolocation) {
navigator.geolocation.getCurrentPosition(function (position) {
coords = position.coords;
let option = {
chatType: "singleChat",
type: "loc",
to: "username",
addr: "四通桥东",
buildingName: "数码大厦",
lat: Math.round(coords.latitude),
lng: Math.round(coords.longitude),
};
let msg = WebIM.message.create(option);
conn.send(msg).then((res)=>{
console.log("Send message success", res);
}).catch((e)=>{
console.log("Send message fail", e);
});
})
}
}
发送透传消息
透传消息是通知指定用户采取特定操作的命令消息。接收方自己处理透传消息。
参考以下代码示例发送和接收透传消息:
function sendCMDMessage() {
let option = {
// 消息类型。
type: "cmd",
// 会话类型:单聊、群聊和聊天室分别为 `singleChat`、`groupChat` 和 `chatRoom`。
chatType: "singleChat",
// 消息接收方:单聊为对方用户 ID,群聊和聊天室分别为群组 ID 和聊天室 ID。
to: "username",
// 自定义动作。对于透传消息,该字段必填。
action: "action",
// 消息扩展信息。
ext: { key: "extends messages" },
};
// 创建一条透传消息。
let msg = WebIM.message.create(option);
// 调用 `send` 方法发送该透传消息。
conn
.send(msg)
.then((res) => {
// 消息成功发送回调。
console.log("Success");
})
.catch((e) => {
// 消息发送失败回调。
console.log("Fail");
});
}
通过透传消息实现输入指示器
输入指示器显示其他用户何时输入消息。通过该功能,用户之间可进行有效沟通,设定对聊天应用程序中新交互的期望。你可以通过透传消息实现输入指示器。
你可以通过透传消息实现输入指示器。下图为输入指示器的工作原理。
监听用户 A 的输入状态。一旦有文本输入,通过透传消息将输入状态发送给用户 B,用户 B 收到该消息,了解到用户 A 正在输入文本。
- 用户 A 向用户 B 发送消息,通知其开始输入文本。
- 收到消息后,如果用户 B 与用户 A 的聊天页面处于打开状态,则显示用户 A 的输入指示器。
- 如果用户 B 在几秒后未收到用户 A 的输入,则自动取消输入指示器。
提示
用户 A 可根据需要设置透传消息发送间隔。
以下示例代码展示如何发送输入状态的透传消息。
发送输入状态的用户。
let previousChangedTimeStamp = 0;
// 监听输入状态的变化
const onInputChange = function () {
const currentTimestamp = new Date().getTime();
if (currentTimestamp - previousChangedTimeStamp > 5000) {
sendBeginTyping();
previousChangedTimeStamp = currentTimestamp;
}
};
// 创建输入状态消息并发送
const sendBeginTyping = function () {
const option = {
// 会话类型:单聊、群聊和聊天室分别为 `singleChat`、`groupChat` 和 `chatRoom`。
chatType: "singleChat",
// 消息类型。
type: "cmd",
// 消息接收方:单聊为对方用户 ID,群聊和聊天室分别为群组 ID 和聊天室 ID。
to: "<target id>",
// 用户自定义操作。
action: "TypingBegin",
};
const typingMessage = message.create(option);
connection
.send(typingMessage)
.then(() => {
console.log("success");
})
.catch((e) => {
console.log("fail");
});
};
接收输入状态的用户。
// 设置状态监听器
let timer;
conn.addEventHandler("message", {
onCmdMessage: (msg) => {
console.log("onCmdMessage", msg);
if (msg.action === "TypingBegin") {
// 这里需更新 UI,显示“对方正在输入”
beginTimer();
}
},
});
const beginTimer = () => {
timer && clearTimeout(timer);
timer = setTimeout(() => {
// 这里需更新 UI,不再显示“对方正在输入”
}, 5000);
};
发送自定义消息
自定义消息为用户自定义的键值对,包括消息类型和消息内容。
参考以下示例代码创建和发送自定义消息:
function sendCustomMsg() {
// 自定义事件。
let customEvent = "customEvent";
// 通过键值对设置自定义消息内容。
let customExts = {};
let option = {
// 消息类型。
type: "custom",
// 消息接收方:单聊为对方用户 ID,群聊和聊天室分别为群组 ID 和聊天室 ID。
to: "username",
// 会话类型:单聊、群聊和聊天室分别为 `singleChat`、`groupChat` 和 `chatRoom`。
chatType: "singleChat",
customEvent,
customExts,
// 消息扩展字段,不能设置为空,即设置为 "ext:null" 这种形式会出错。
ext: {},
};
// 创建一条自定义消息。
let msg = WebIM.message.create(option);
// 调用 `send` 方法发送该自定义消息。
conn
.send(msg)
.then((res) => {
// 消息成功发送回调。
console.log("Success");
})
.catch((e) => {
// 消息发送失败回调。
console.log("Fail");
});
}
发送合并消息
为了方便消息互动,即时通讯 IM 自 4.2.0 版本开始支持将多个消息合并在一起进行转发。你可以采取以下步骤进行消息的合并转发:
- 利用原始消息列表创建一条合并消息。
- 发送合并消息。
- 对端收到合并消息后进行解析,获取原始消息列表。
创建和发送合并消息
你可以调用 message.create
方法创建一条合并消息,然后调用 connection.send
方法发送该条消息。
创建合并消息时,需要设置以下参数:
属性 | 类型 | 描述 |
---|---|---|
chatType | ChatType | 会话类型。 |
type | 'combine' | 消息类型。 |
to | String | 消息接收方。该字段的设置取决于会话类型: - 单聊:对方用户 ID; - 群聊:群组 ID; - 子区会话:子区 ID; - 聊天室聊天:聊天室 ID。 |
title | String | 合并消息的标题。 |
summary | String | 合并消息的概要。 |
compatibleText | String | 合并消息的兼容文本。 兼容文本起向下兼容不支持消息合并转发的版本的作用。当支持合并消息的 SDK 向不支持合并消息的低版本 SDK 发送消息时,低版本的 SDK 会将该属性解析为文本消息的消息内容。 |
messageList | MessagesType[] | 合并消息的消息列表。该列表最多包含 300 个消息。 |
onFileUploadComplete | (data: { url: string; secret: string;}) => void | 合并消息文件上传完成的回调。 |
onFileUploadError | (error: any) => void | 合并消息文件上传失败的回调。 |
提示
- 合并转发支持嵌套,最多支持 10 层嵌套,每层最多 300 条消息。
- 只有成功发送或接收的消息才能合并转发。
示例代码如下:
let option = {
chatType: "singleChat",
type: "combine",
to: "userId",
compatibleText: "SDK 版本低,请升级",
title: "聊天记录",
summary: "hi",
messageList: [
{
type: "txt",
chatType: "singleChat",
// ...
},
],
onFileUploadComplete: (data) => {
option.url = data.url;
},
};
let msg = WebIM.message.create(option);
conn.send
.send(msg)
.then((res) => {
console.log("发送成功", res);
})
.catch((err) => {
console.log("发送失败", err);
});
接收合并消息与接收普通消息的操作相同,唯一不同是对于合并消息来说,消息接收事件为 onCombineMessage
。
对于不支持合并转发消息的 SDK 版本,该类消息会被解析为文本消息,消息内容为 compatibleText
携带的内容,其他字段会被忽略。
解析合并消息
合并消息实际上是一种附件消息。收到合并消息后,你可以调用 downloadAndParseCombineMessage
方法下载合并消息附件并解析出原始消息列表。
connection
.downloadAndParseCombineMessage({
url: msg.url,
secret: msg.secret,
})
.then((res) => {
console.log("合并消息解析后的消息列表", res);
});
发送定向消息
发送定向消息是指向群组或聊天室的单个或多个指定的成员发送消息,其他成员不会收到该消息。
该功能适用于文本消息、图片消息和音视频消息等全类型消息,最多可向群组或聊天室的 20 个成员发送定向消息。
提示
- 仅 SDK 4.1.7 及以上版本支持。
- 定向消息不写入服务端会话列表,不计入服务端会话的未读消息数。
- 定向消息不支持消息漫游功能,因此从服务器拉取漫游消息时,不包含定向消息。
发送定向消息的流程与发送普通消息相似,唯一区别是需要设置定向消息的接收方。
下面以文本消息为例介绍如何发送定向消息,示例代码如下:
// 发送定向文本消息。
function sendTextMessage() {
let option = {
// 消息类型。
type: "txt",
// 消息内容。
msg: "message content",
// 消息接收方所在群组或聊天室的 ID。
to: "groupId",
// 会话类型:群聊和聊天室分别为 `groupChat` 和 `chatRoom`。
chatType: "groupChat",
// 消息的接收方列表。最多可传 20 个接收方的用户 ID。若不设置该字段或传入数组类型之外的值,如字符串,则消息发送给群组或聊天室的所有成员。
receiverList: ['uId1','uId2'],
};
// 创建文本消息。
let msg = WebIM.message.create(option);
// 调用 `send` 方法发送该文本消息。
conn.send(msg).then((res)=>{
console.log("Send message success",res);
}).catch((e)=>{
console.log("Send message fail",e);
});
}
接收定向消息与接收普通消息的操作相同,详见接收消息。
使用消息扩展
如果上述消息类型无法满足要求,你可以使用消息扩展为消息添加属性。这种情况可用于更复杂的消息传递场景,例如消息中需要携带被回复的消息内容或者是图文消息等场景。
function sendTextMessage() {
let option = {
type: "txt",
msg: "message content",
to: "username",
chatType: "singleChat",
// 消息扩展信息。扩展字段为可选,若带有该字段,值不能为空,即 "ext:null" 会出错。
ext: {
key1: "Self-defined value1",
key2: {
key3: "Self-defined value3",
},
},
};
let msg = WebIM.message.create(option);
// 调用 `send` 方法发送该扩展消息。
conn
.send(msg)
.then((res) => {
console.log("send private text Success");
})
.catch((e) => {
console.log("Send private text error");
});
}