netty client server交互问题

Server与Client建立连接后，会执行以下的步骤：

1、Client向Server发送消息

2、Server接收客户端发送的消息，并解析，根据解析内容向客户端发送消息
3、客户端接收到服务端消息，解析，根据解析结果，再发给客户端。
知道出现结束标志。

private void handleWebSocketFrame(ChannelHandlerContext ctx,
WebSocketFrame frame) {

    // 是否关闭
    if (frame instanceof CloseWebSocketFrame) {
        if(null != ctx && null != ctx.channel()){
            handshaker.close(ctx.channel(),
                    (CloseWebSocketFrame) frame.retain());
        }
        return;
    }

    // 是否ping
    if (frame instanceof PingWebSocketFrame) {
        ctx.channel().write(
                new PongWebSocketFrame(frame.content().retain()));
        return;
    }

    // 非文本
    if (!(frame instanceof TextWebSocketFrame)) {
        throw new UnsupportedOperationException(String.format(
                "%s frame types not supported", frame.getClass().getName()));
    }

    // 接收到的消息
    String msg = ((TextWebSocketFrame) frame).text();
    // 发送者的通道
    Channel incoming = ctx.channel();

    if(StringUtils.isEmpty(msg)){
        return;
    }else if("@heart".equals(msg)){
        // 收到心跳包，不做处理

// System.out.println("received[" + QuestionsAndAnswersUtil.getChannelUserId(incoming) + "]msg:" + msg);
return;
}else if ("1".equals(msg)){
return;
}

    JSONObject jsonMsg = null;
    try{
        jsonMsg = JSONObject.fromObject(msg);
    }catch(JSONException e){

    }

    if(null == jsonMsg){
        // 收到的数据不是json格式数据，做普通聊天内容处理
        dataCache.channels.writeAndFlush(new TextWebSocketFrame("["
                + QuestionsAndAnswersUtil.getChannelUserId(incoming) + "]:" + msg + "\n"+"online user num："+dataCache.channels.size()));
        return;
    }

    String type = jsonMsg.getString("type");

    switch (type) {
    case QuestionsAndAnswers.PackType.USER_ANSWER:
        questionsAndAnswersService.userAnswer(ctx,jsonMsg);
        break;
    default:
        break;
    }

你要问什么问题？麻烦写出问题

题主，你是想要“netty实现 server client通信”实例或教程么，这个百度一下就好了。

只要建立起来Socket连接，你想client给server发也行，server给client发也行，将socket连接断开也行，你想怎么用就怎么用的了。

1 /**
2 * 基于TCP协议的Socket通信，实现用户登录，服务端
3 */
4 //1、创建一个服务器端Socket，即ServerSocket，指定绑定的端口，并监听此端口
5 ServerSocket serverSocket =newServerSocket(10086);//1024-65535的某个端口
6 //2、调用accept()方法开始监听，等待客户端的连接
7 Socket socket = serverSocket.accept();
8 //3、获取输入流，并读取客户端信息
9 InputStream is = socket.getInputStream();
10 InputStreamReader isr =newInputStreamReader(is);
11 BufferedReader br =newBufferedReader(isr);
12 String info =null;
13 while((info=br.readLine())!=null){
14 System.out.println("我是服务器，客户端说："+info)；
15 }
16 socket.shutdownInput();//关闭输入流
17 //4、获取输出流，响应客户端的请求
18 OutputStream os = socket.getOutputStream();
19 PrintWriter pw = new PrintWriter(os);
20 pw.write("欢迎您！");
21 pw.flush();
22
23
24 //5、关闭资源
25 pw.close();
26 os.close();
27 br.close();
28 isr.close();
29 is.close();
30 socket.close();
31 serverSocket.close();