鸿蒙NEXT版仿微信聊天App的群聊功能
鸿蒙NEXT版仿微信聊天App的群聊功能
上一节我们通过自定义图片分段结构实现了从SocketIO服务器接收图片的功能，至此可以在单聊中发送文本和图片了。不过若想在群聊中发送文本和图片，还得构建一套群聊机制，把群成员发送的消息转发给其他的群成员。具体的群聊构建过程分为下列几个事件处理。
一、处理入群事件
每当一个新成员加入群聊时，该成员会发出join_group通知SocketIO服务器，表示自己已经入群了。然后SocketIO服务器轮询所有在线的群成员，向其他在线的群成员发出person_in_group通知，表示现有XXX新成员入群了。下面是处理入群事件的SocketIO服务端代码例子：
// 添加入群的事件监听器
server.addEventListener("join_group", String.class, (client, content, ackSender) -> {
String sessionId = client.getSessionId().toString();
JSONObject json = JSONObject.parseObject(content);
JoinInfo info = (JoinInfo) JSONObject.toJavaObject(json, JoinInfo.class);
if (!groupMap.containsKey(info.getGroup_name())) {
groupMap.put(info.getGroup_name(), new HashMap<String, String>());
}
for (Map.Entry<String, Map<String, String>> group : groupMap.entrySet()) {
if (info.getGroup_name().equals(group.getKey())) {
group.getValue().put(sessionId, info.getUser_name());
for (Map.Entry<String, String> user : group.getValue().entrySet()) {
clientMap.get(user.getKey()).sendEvent("person_in_group", info.getUser_name().toString());
}
}
}
});对于鸿蒙App而言，入群的新成员通过以下代码向SocketIO服务器发送入群通知。
this.client.emit('join_group', msg)而群聊的其他成员通过以下代码从SocketIO服务器接收入群通知。
this.client.on('person_in_group', (person_name: string) => {
// 这里暂时省略群成员的入群提示处理
})二、处理退群事件
每当一个群成员退出群聊时，该成员会发出leave_group通知SocketIO服务器，表示自己已经退群了。然后SocketIO服务器轮询所有在线的群成员，向其他在线的群成员发出person_out_group通知，表示原来的XXX成员退群了。处理退群事件的SocketIO服务端可参考上面的处理入群事件代码。
对于鸿蒙App而言，入群的新成员通过以下代码向SocketIO服务器发送退群通知。
this.client.emit('leave_group', msg)
而群聊的其他成员通过以下代码从SocketIO服务器接收退群通知。
this.client.on('person_out_group', (person_name: string) => {
// 这里暂时省略群成员的退群提示处理
})三、处理群文本消息的发送和接收
每当一个群成员发送聊天文本消息时，该成员会发出send_group_message通知SocketIO服务器，表示自己发表了某段文本。然后SocketIO服务器轮询所有在线的群成员，向其他在线的群成员发出receive_group_message通知，表示有成员发表了聊天文本消息。下面是处理群消息收发事件的SocketIO服务端代码例子：
// 添加群消息发送的事件监听器
server.addEventListener("send_group_message", String.class, (client, content, ackSender) -> {
String sessionId = client.getSessionId().toString();
JSONObject json = JSONObject.parseObject(content);
MessageInfo message = (MessageInfo) JSONObject.toJavaObject(json, MessageInfo.class);
for (Map.Entry<String, Map<String, String>> group : groupMap.entrySet()) {
if (message.getTo().equals(group.getKey())) {
for (Map.Entry<String, String> user : group.getValue().entrySet()) {
if (!user.getValue().equals(message.getFrom())) {
String resp = JSONObject.toJSONString(message);
clientMap.get(user.getKey()).sendEvent("receive_group_message", resp.toString());
}
}
break;
}
}
});对于鸿蒙App而言，群成员通过以下代码从SocketIO服务器接收群文本消息。
this.client.on('receive_group_message', (data: string) => {
// 这里暂时省略群文本消息的解析和展示处理
})综合上述几个群聊事件处理，运行演示App观察到的仿微信群聊效果如下图所示，分别是甲、乙、丙成员的App界面截图。
至此，本系列的“仿微信聊天”App开发技术分享全部完结啦，各位小伙伴们，你们有没有得到什么收获呢？欢迎留言跟帖。
腾讯云开发者
