乐趣区

用Java构建一个简单的WebSocket聊天项目之新增HTTP接口调度

本文首发公众号与个人博客:Java 猫说 & 猫叔的博客 | MySelf,转载请申明出处。
前言
大家可以看看上一篇:用 Java 构建一个简单的 WebSocket 聊天室

在上一篇文章中我们已经实现了:自我对话、好友交流、群聊、离线消息等的功能。
而本篇,我们的框架升级了,并且开通了几个新的 HTTP 接口功能,同时也把原先框架的一些异常做了处理。
我们将使用更少的代码完成功能更加完善的聊天项目!
采用框架
我们整个 Demo 基本不需要大家花费太多时间,就可以实现以下的功能。

用户 token 登录校验
自我聊天
点对点聊天
群聊
获取在线用户数与用户标签列表
发送系统通知

首先,我们需要介绍一下我们今天打算采用的框架,InChat : 一个轻量级、高效率的支持多端(应用与硬件 Iot)的异步网络应用通讯框架,采用这个框架,我们基本上只需要两三个类就可以实现我们今天需要的功能了。
先看看效果

需要了解 SSM & SpringBoot 吗?
InChat,本身不依赖于任何的底层框架,所以大家只要会基本的 Java 语言就可以实现一套自己的 WebSocket 聊天室。
框架使用手册(新版 V1.1.2 刚刚发布)
关于详细的手册说明,大家可以看看官网的介绍:

V1.1.2 版本使用说明
V1.1.2 版本视频教学

<dependency>
<groupId>com.github.UncleCatMySelf</groupId>
<artifactId>InChat</artifactId>
<version>1.1.2</version>
</dependency>
开始 Demo 搭建
构建一个空的 Maven 项目
我们不需要依赖其他的 Maven 包,只要本文提及的框架即可。
<dependency>
<groupId>com.github.UncleCatMySelf</groupId>
<artifactId>InChat</artifactId>
<version>1.1.2</version>
</dependency>
InChat 启动参数可以自配置
你只需要继承 InChat 的默认配置类 InitNetty 即可,如下
public class MyInit extends InitNetty {
/** 自定义启动监听端口 */
@Override
public int getWebport() {
return 8090;
}
}
获取聊天消息数据
此接口与原先一样,仅修改了方法名
public class DataBaseServiceImpl implements InChatToDataBaseService {

@Override
public Boolean writeMessage(InChatMessage message) {
System.out.println(message.toString());
return true;
}
}
登录校验与群聊消息
此接口没有做过多的修改
public class VerifyServiceImpl implements InChatVerifyService {

@Override
public boolean verifyToken(String token) {
return true;
}

@Override
public JSONArray getArrayByGroupId(String groupId) {
JSONArray jsonArray = JSONArray.parseArray(“[\”1111\”,\”2222\”,\”3333\”]”);
return jsonArray;
}
}
服务端发送通知消息枚举类
此接口具有 Demo 模板,用户需要继承 InChat 框架的 FromServerService 接口,同时该接口注释也有实例 demo,我们需要实现一个自定义的枚举,你可以这样写:
public enum FromServerServiceImpl implements FromServerService {

// 你可以自定义自己的系统消息,请以 Integer-String 的形式
TYPE1(1,”【系统通知】您的账号存在异常,请注意安全保密信息。”),
TYPE2(2,”【系统通知】恭喜您连续登录超过 5 天,奖励 5 积分。”);

private Integer code;

private String message;

FromServerServiceImpl(Integer code, String message){
this.code = code;
this.message = message;
}

public Integer getCode() {
return code;
}

// 实现接口的方法,遍历本枚举的 code,获取对应的消息,作为系统消息发送
public String findByCode(Object code) {
Integer codes = (Integer)code;
for (FromServerServiceImpl item: FromServerServiceImpl.values()) {
if (item.code == codes){
return item.message;
}
}
return null;
}

public void setCode(Integer code) {
this.code = code;
}

public String getMessage() {
return message;
}

public void setMessage(String message) {
this.message = message;
}

}
启动项目
1.1.2 版本的启动项目变得异常的简单,你只需要配置启动的配置工厂即可。
public class application {

public static void main(String[] args) {
// 配置你的自定义配置
ConfigFactory.initNetty = new MyInit();
// 配置校验类
ConfigFactory.inChatVerifyService = new VerifyServiceImpl();
// 配置消息接收处理类
ConfigFactory.inChatToDataBaseService = new DataBaseServiceImpl();
// 配置服务端系统消息枚举,这里的值无所谓 TYPE1 或者 TYPE2 或者 TYPEN 均可以
ConfigFactory.fromServerService = FromServerServiceImpl.TYPE1;
// 启动 InChat
InitServer.open();
}

}
项目效果
启动成功
DEBUG – -Dio.netty.threadLocalDirectBufferSize: 0
DEBUG – -Dio.netty.maxThreadLocalCharBufferSize: 16384
INFO – 服务端启动成功【192.168.56.1:8090】
当聊天连接未注册情况下,客户端自动断开后,服务会自动包对应的异常
INFO – [Handler:channelInactive]/192.168.56.1:8090 关闭成功
ERROR – [捕获异常:NotFindLoginChannlException]-[Handler:channelInactive] 关闭未正常注册链接!
原先的自我发送, 点对点发送, 群聊均与原来一样原先的接口说明可以看上一版本:v1.1.0-alpha 版本使用说明

新功能添加 HTTP
新增 HTTP 接口三个,在你启动 Inchat 的时候,默认启动,对于你的其他 web API 并无任何影响,它是一个 IM 的辅助作用。本版本不支持用户自定义相关的 InChat HTTP 接口
获取在线用户数

地址:[ip:端口]/get_size GET

返回值

{
“code”: 200,
“data”: {
“online”: 1,// 当前在线数
“time”: “Jan 3, 2019 10:06:45 PM”// 查询时间
}
}
获取在线用户标识

地址:[ip: 端口]/get_list GET

返回值

{
“code”: 200,
“data”: {
// 返回在线用户列表
“tokens”: [
“1111”
]
}
}
根据用户标签,发送系统指定消息

地址:[ip: 端口]/send_from_server POST

参数:token(你可以从 get_list 中得到在线用户标签)、value(你在系统中添加枚举的 code 值,这里不接受字符串)
返回值

{
“code”: 400,
“data”: {
“message”: “ 通知发送成功 ”
}
}
(有个小 BUG,返回值 code 应该是 200)

关于前端
InChat : 一个轻量级、高效率的支持多端(应用与硬件 Iot)的异步网络应用通讯框架,大家可以直接来这个项目下获取前端页面,或者直接访问这个地址:https://github.com/UncleCatMy…
对于这个前端页面,我们需要更改一下 IP 地址。
运行调试项目
接下来直接启动后端项目,当我们看到以下的信息,则项目启动成功。
INFO – 服务端启动成功【192.168.1.121:8090】
这里的 IP 需要更换以下读者启动后的 IP 地址。
接着直接用浏览器打开 chat.html 的页面即可,关于 js 的方法,大家可以看看 InChatV1.1.0 版本使用说明。
运行效果已经提前展示啦!
公众号:Java 猫说
现架构设计(码农)兼创业技术顾问,不羁平庸,热爱开源,杂谈程序人生与不定期干货。

退出移动版