Java自定义协议进行socket连接的简单认证和消息.doc

Java自定义协议进行socket连接的简单认证和消息 1、 服务器端的几次连接认证和状态的改变如上图所示： 1、服务器端进行协议认证的关键代码： public static String processInput(String theInput) String theOutput = null; if (state = WAITING) theOutput = waiting; state = 1; else if (state = 1) if (theInput.equalsIgnoreCase(hello!) theOutput = step1.; state = 2; else theOutput = Sorry, you are wrong. Please try again.; state = 0; else if (state = 2) if (theInput.equalsIgnoreCase(peng_zhanxuan) theOutput = step2; state = 3; else theOutput = error!; state = 0; else if (state = 3) if (theInput.equalsIgnoreCase(try!) theOutput = success!; state = 4; else theOutput = error!; state = 0; return theOutput; 2、客户端进行请求连接的关键代码： s = new Socket(,2010); InputStreamReader isr=new InputStreamReader(s.getInputStream(); BufferedReader br=new BufferedReader(isr); PrintWriter pw=new PrintWriter(s.getOutputStream(),true); String receive = null; pw.println(start); receive = br.readLine(); jta.append(来自服务器的验证消息： + receive + n); pw.println(hello!); receive = br.readLine(); jta.append(来自服务器的验证消息： + receive + n); pw.println(peng_zhanxuan); receive = br.readLine(); jta.append(来自服务器的验证消息： + receive + n); pw.println(try!); receive = br.readLine(); jta.append(来自服务器的验证消息： + receive + n); /如果验证成功则开启线程 if(receive.equals(success!) ClientThread ct = new ClientThread(s,jta); ct.start(); jta.append(连接成功！ + n); else isr.close(); pw.close(); br.close(); s.close(); jta.append(服务器端认证失败！ + n); 3、服务器端接收连接认证分析的代码： if(ConnProtocol.getState() != 4) System.out.println(=连接认证=); String outMes = ConnPcessInput(info); pw.println(outMes); if(ConnProtocol.getState() = 0) break; # 2、使用自定义协议封装的消息结构如上图所示： 1、客户端发送消息封装信息的关键代码： String version = v1.0; String author = pzx; SimpleDateFormat simpleDateFormat =new SimpleDateFormat(yyyy-mm-dd hh:mm:ss); Date date = new Date(); String time = simpleDateFormat.format(date); String end = end; if(e.getSource()=jb) String info=jtf.getText(); /把客户端发送的信息显示到jta jta.append(客户机对服务器说：rn+ +info+rn); /在这里进行对数据的封装 String message = version + author + time + info + end; PrintWriter pw;2、服务器解析接收到的信息的关键代码：else /在这里进行协议解析 System.out.println(=协议解析=); Protocol pro = new Protocol(); String result = pro.analyzing(info); if(result = pzx ) if(pro.getMessage_text().equals(bye) /服务器端转发给客户端socket关闭中，也可不转发直接在接受到消息前客户端自动关闭，也不需要第二步了 pw.println(ok); pw.close(); br.close(); isr.close(); ss.close(); break; /退出服务器的接收循环，但还在等待客