基于Netty的一个WeoSocket通信服务器与客户端代码(非JS代码)
咳咳，在这里呢，小轩就不多说什么是WebSocket的，还有呢，小轩为什么不给出JS-Client代码？网上太多代码可以用了。小轩这里的WebSocket客户端是非JS客户端，因为小轩的项目后台逻辑要与WebSocket服务器通信，所以才搞了个客户端出来。不多说，先上成果图。
-
启动WebSocket服务器
-
启动项目（客户端1）
-
使用ws-js客户端与服务器建立连接（客户端2）
-
调用项目接口，由客户端1给客户端2发送消息。
这里，小轩可以支持文本消息，也可以支持二进制数据。当然，逻辑写的很简单，就是简单的发送消息。但是可以在此基础上进行业务逻辑的修改，从而达到符合自己的业务需求。
好了，图呢，就先到这里，小轩这边已经在正常使用中。没有视频演示还真是硬伤。
之所以看到tdg_yyx跟连接里面的不一样，是因为在小轩的项目中集成的客户端中加了系统前缀。所以才会有这样的演示图。当然，如果想知道具体再怎么使用的话，依旧可以联系小轩我哦。
例子中的编码解码数据是使用的MsgPack对对象进行了序列化。但是从服务器发给浏览器客户端的时候使用的是文本消息哦。
项目源码已共享至github中，另起了一个新的repository哦。与之前的demo分开了。可以直接拿下来进行修改的哦。
目录结构
|- xpush
|——push-client
|————org.yyx.message.push.client
|——————client // 客户端代码
|——————config // 从yml文件中加载配置的Netty配置类包
|——————entity // 用来在服务器与客户端之间进行传输的实体类包
|——————handler // WebSocket客户端处理包
|——————listener // 用于启动客户端的监听器
|——————util // 此处应该写接口，主要用来做传输消息的逻辑
|————PushClientApplication // SpringBoot 启动类
|——push-server
|————org.yyx.message.push.server
|——————config // 从yml文件中加载配置的Netty配置类包
|——————entity // 用来在服务器与客户端之间进行传输的实体类包
|——————handler // WebSocket服务端处理包
|——————listener // WebSocket服务端监听器
|——————main // 服务端代码
|——————util // 此处应该写接口，主要用来做传输消息的逻辑
|————ServerApplication.java // SpringBoot 启动类
服务端的处理
- WebSocketUrl为ws://localhost:9999/oa/web_socket/{uri} 其中{uri}用来接收业务参数
- 如果服务端接收的消息是文本消息，则返回给客户端的内容为：你发的消息是：+ 原消息内容
- 如果是二进制数据，则会对其进行解码，编解码使用的是MessagePack工具。若想自己开发自己的业务逻辑，可以将handlerWebSocketFrame方法抽出到接口中，根据不同的业务走自己的业务逻辑。在源码中，服务端和客户端使用同一个实体类。进行简易的点对点通信。详见WebSocketMessageEntity实体类。
客户端的处理
- 在源码中，客户端连接的是本地服务器，连接成功后进行WebSocket通信。url为：ws://127.0.0.1:9999/web_socket/${userName}其中 userName为用户名。即我自己的业务参数。
- 连接成功后，将userName的Channel保留。当需要给服务端发送消息时，根据用户名获取自己与服务器已连接的通道，进行消息传输。
- 现在客户端的处理逻辑是发送二进制数据，指定服务端将消息发送给哪个客户端。如果有自己的业务逻辑，可根据服务端业务进行相应的修改。
测试用例
- 启动服务端。
- 将客户端代码集成在已有项目中（此处我集成在了一个基于tomcat应用服务器的web项目）
- 启动客户端（此处，我将项目以一个用户的身份与服务端进行通信system_manage)
- 通过web项目的登陆入口，将一个个用户与服务端进行连接（项目中的前端页面，使用js直接与服务端通信，但触发点是登陆系统之后）
- 用户A发送消息给用户B
到目前为止，仍然没有看到客户端的作用对吧。不急，向下看。
当Web服务器处理了一些业务，需要给当前用户A发送消息通推送，可以在后台直接调用客户端发送消息给用户的方法，此时，就用到客户端了。
WEB后台调用client发送消息的方法，以上面提到的system_manage身份发送消息给指定用户。消息以二进制数据到达服务端，服务端有写好的业务逻辑，将消息解码后，回写数据给用户A（没错，用户A就是通过js与服务端建立连接的前台用户）当然，这里也可以做到给所以在线用户发送消息。这里就不多说了。原理是一样的。