qq_40093149
干物妹小白
采纳率100%
2018-03-08 03:17 浏览 1.4k
已采纳

netty client server交互问题

10

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

1、Client向Server发送消息

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

  • 点赞
  • 写回答
  • 关注问题
  • 收藏
  • 复制链接分享
  • 邀请回答

4条回答 默认 最新

  • 已采纳
    daidaineteasy 晓呆同学 2018-03-08 07:48

    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;
        }
    
    点赞 评论 复制链接分享
  • baidu_30233079 baidu_30233079 2018-03-08 03:49

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

    点赞 1 评论 复制链接分享
  • daidaineteasy 晓呆同学 2018-03-08 04:03

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

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

    点赞 评论 复制链接分享
  • daidaineteasy 晓呆同学 2018-03-08 07:12

    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();

    点赞 评论 复制链接分享

相关推荐