摘要：唯一的知識(shí)點(diǎn)就是的基礎(chǔ)使用。可以簡(jiǎn)單的理解下面的代碼就構(gòu)建了一個(gè)服務(wù)器。握手完成之后的消息傳遞則在中處理。實(shí)際情況下，不可能那么多人同時(shí)說(shuō)話廣播，而是說(shuō)話的人少，接受廣播的人多。

SF 官方首頁(yè)推薦《PHP進(jìn)階之路》（你又多久沒(méi)有投資自己了？先看后買）

我們下面則將一些實(shí)際場(chǎng)景都添加進(jìn)去，比如用戶身份的驗(yàn)證，游客只能瀏覽不能發(fā)言，多房間（頻道）的聊天。
該博客非常適合 Java 新手，非常適合作為學(xué)習(xí) Java 的切入點(diǎn)，不需要考慮tomcat、spring、mybatis等。
唯一的知識(shí)點(diǎn)就是 maven 的基礎(chǔ)使用。

https://github.com/zhoumengka...

├── WebSocketServer.java                啟動(dòng)服務(wù)器端口監(jiān)聽(tīng)
├── WebSocketServerInitializer.java     初始化服務(wù)
├── WebSocketServerHandler.java         接管WebSocket數(shù)據(jù)連接
├── dto
│   └── Response.java                   返回給客戶端數(shù)據(jù)對(duì)象
├── entity
│   └── Client.java                     每個(gè)連接到WebSocket服務(wù)的客戶端對(duì)象
└── service
    ├── MessageService.java             完成發(fā)送消息
    └── RequestService.java             WebSocket初始化連接握手時(shí)的數(shù)據(jù)處理

客戶端將用戶 id 、進(jìn)入的房間的 rid、用戶 token json_encode，例如{id:1;rid:21;token:"43606811c7305ccc6abb2be116579bfd"}。然后在 base64 處理，通過(guò)參數(shù)request傳到服務(wù)器，然后在服務(wù)器做 id 和 token 的驗(yàn)證（我的做法是 token 存放在redis string 5秒的過(guò)期時(shí)間）

使用一個(gè)Map channelGroupMap 來(lái)存放各個(gè)房間（頻道），以客戶端傳握手時(shí)傳過(guò)來(lái)的 base64 字符串中獲取到定義的房間 ID，然后為該房間 ID 新建一個(gè)ChannelGroup（ChannelGroup 方便對(duì)該組內(nèi)的所有客戶端廣播消息）

現(xiàn)在大家都有自己的包管理工具，不需要實(shí)現(xiàn)下載了然后放到本地lib庫(kù)中，和 nodejs 的 npm, php 的 compser 一樣。

    
        io.netty
        netty-all
        5.0.0.Alpha2
    
    
        com.jcraft
        jzlib
        1.1.2
    
    
        org.json
        json
        20141113
    
    
        commons-codec
        commons-codec
        1.10
    

這段代碼需要理解嗎？這是 netty 的套路，可以先記住 netty 的線程模型是一個(gè) react 的一種變型，這里有兩個(gè)nio線程組，一個(gè)是接受客戶端的請(qǐng)求，一個(gè)是worker組專門處理客戶端的請(qǐng)求。

可以簡(jiǎn)單的理解下面的代碼就構(gòu)建了一個(gè)nginx服務(wù)器。所以不用管。

package net.mengkang;

import io.netty.bootstrap.ServerBootstrap;
import io.netty.channel.Channel;
import io.netty.channel.EventLoopGroup;
import io.netty.channel.nio.NioEventLoopGroup;
import io.netty.channel.socket.nio.NioServerSocketChannel;
import io.netty.handler.logging.LogLevel;
import io.netty.handler.logging.LoggingHandler;


public final class WebSocketServer {

    private static final int PORT = 8083;

    public static void main(String[] args) throws Exception {

        EventLoopGroup bossGroup = new NioEventLoopGroup(1);
        EventLoopGroup workerGroup = new NioEventLoopGroup();
        try {
            ServerBootstrap b = new ServerBootstrap();
            b.group(bossGroup, workerGroup)
                    .channel(NioServerSocketChannel.class)
                    .handler(new LoggingHandler(LogLevel.INFO))
                    .childHandler(new WebSocketServerInitializer());

            Channel ch = b.bind(PORT).sync().channel();
            ch.closeFuture().sync();
        } finally {
            bossGroup.shutdownGracefully();
            workerGroup.shutdownGracefully();
        }
    }
}

package net.mengkang;

import io.netty.channel.ChannelInitializer;
import io.netty.channel.ChannelPipeline;
import io.netty.channel.socket.SocketChannel;
import io.netty.handler.codec.http.HttpObjectAggregator;
import io.netty.handler.codec.http.HttpServerCodec;
import io.netty.handler.codec.http.websocketx.extensions.compression.WebSocketServerCompressionHandler;


public class WebSocketServerInitializer extends ChannelInitializer {

    @Override
    public void initChannel(SocketChannel ch) throws Exception {
        ChannelPipeline pipeline = ch.pipeline();

        pipeline.addLast(new HttpServerCodec());
        pipeline.addLast(new HttpObjectAggregator(65536));
        pipeline.addLast(new WebSocketServerCompressionHandler());
        pipeline.addLast(new WebSocketServerHandler());
    }
}

下面程序中最的處理在握手階段handleHttpRequest，里面處理參數(shù)的判斷，用戶的認(rèn)證，登錄用戶表的維護(hù)，直播房間表維護(hù)。詳細(xì)的請(qǐng)大家對(duì)照代碼來(lái)瀏覽。
握手完成之后的消息傳遞則在handleWebSocketFrame中處理。
整理的執(zhí)行流程，大家可以對(duì)各個(gè)方法打斷點(diǎn)予以調(diào)試，就會(huì)很清楚整個(gè)執(zhí)行的脈絡(luò)啦。

package net.mengkang;

import io.netty.buffer.ByteBuf;
import io.netty.buffer.Unpooled;
import io.netty.channel.*;
import io.netty.channel.group.ChannelGroup;
import io.netty.channel.group.DefaultChannelGroup;
import io.netty.handler.codec.http.*;
import io.netty.handler.codec.http.websocketx.*;
import io.netty.util.CharsetUtil;
import io.netty.util.concurrent.GlobalEventExecutor;
import net.mengkang.dto.Response;
import net.mengkang.entity.Client;
import net.mengkang.service.MessageService;
import net.mengkang.service.RequestService;
import org.json.JSONObject;

import java.util.HashMap;
import java.util.List;
import java.util.Map;

import static io.netty.handler.codec.http.HttpHeaderNames.HOST;
import static io.netty.handler.codec.http.HttpMethod.GET;
import static io.netty.handler.codec.http.HttpResponseStatus.*;
import static io.netty.handler.codec.http.HttpVersion.HTTP_1_1;

public class WebSocketServerHandler extends SimpleChannelInboundHandler