代理服务器设计.docxVIP

代理服务器设计一、实验题目：基于socket通信的代理服务器设计。二、实验要求：两台客户端不能直接通信，只能通过代理服务器相连接而通信。两台客户端之间实现消息的传输。两台客户端之间可以实现大文件的传输。三、实验原理：服务器端：1．建立服务器短的Socket，监听某个端口，开始侦听网络中的请求。2. 当检测到来自客户端的连接请求时，向客户端发送收到连接请求的信息，并建立与客户端之间的连接。3. 当完成通信之后，服务器关闭与客户端的Socket连接。客户端：建立客户端的Socket，确定要连接的服务器的端口号。发送连接请求到服务器，并等待服务器的反馈信息。连接成功之后，与服务器进行数据的交互。数据处理完毕之后，关闭自身的Socket连接。四、实验代码：服务器端：服务器端建立Socket代码：publicclass ServerListener extends Thread {@Overridepublicvoid run() {try {ServerSocket serverSocket = new ServerSocket(12345);ChatSocket cs = new ChatSocket();while (true) {Socket socket = serverSocket.accept();System.out.println(客户端连接了端口12345);cs.setSocket(socket);}} catch (IOException e) {e.printStackTrace();}}}服务器端接收与转发消息：class Thread1to2 implements Runnable{publicvoid run() {try {InputStream input = socket1.getInputStream();BufferedReaderbr = newBufferedReader(new InputStreamReader(input));String str = br.readLine();char a = str.charAt(0);System.out.println(this.toString()+msg:+str); System.out.println(zhiqian:+a); OutputStream output = socket2.getOutputStream();if(a == @){ String filesize = br.readLine();long flen = Long.parseLong(filesize);//读取文件大小output.write(new String(str+\r\n).getBytes());output.write(new String(flen+\r\n).getBytes());System.out.println(转发文件:+str+/+flen); long fsum = 0;while(true){byte cbyte[] = newbyte[(flen-fsum = 1024*8)?(1024*8):(int)(flen-fsum)];int rlen = input.read(cbyte);if (rlen 0) break;output.write(cbyte,0,rlen);fsum += rlen;System.out.println(转发了：+rlen+/+fsum );if (fsum=flen) break;}output.flush(); }else{System.out.println(tt+str);output.write((str+\n).getBytes(UTF-8));System.out.println(tt111+str);while ((str = br.readLine()) != null) {output.write((str+\n).getBytes(UTF-8));}socket2.getOutputStream().flush(); }//br.close();} catch (UnsupportedEncodingException e) {e.printStackTrace();} catch (IOException e) {e.printStackTrace();} catch (Exception e){System.out.println(this.toString());e.printStackTrace();}}}客户端：客户端建立Socket：publicvoidConnectServer(){try{Socket socket = ne