本文共 2063 字,大约阅读时间需要 6 分钟。
package com.cug.net09;import java.io.BufferedReader;import java.io.BufferedWriter;import java.io.FileReader;import java.io.IOException;import java.io.InputStreamReader;import java.io.OutputStreamWriter;import java.net.Socket;public class ClientDemo { public static void main(String[] args) throws IOException { Socket s = new Socket("bluze",11111); BufferedReader br = new BufferedReader(new FileReader("UserThread.java")); BufferedWriter bw = new BufferedWriter(new OutputStreamWriter(s.getOutputStream())); String line = null; while((line = br.readLine())!=null){ bw.write(line); bw.newLine(); bw.flush(); } s.shutdownOutput(); BufferedReader brClient = new BufferedReader(new InputStreamReader(s.getInputStream())); System.out.println(brClient.readLine()); br.close(); s.close(); }}
package com.cug.net09;import java.io.IOException;import java.net.ServerSocket;import java.net.Socket;public class ServerDemo { public static void main(String[] args) throws IOException { ServerSocket ss = new ServerSocket(11111); while(true){ Socket s = ss.accept(); new Thread((new UserThread(s))).start(); } }}
package com.cug.net09;import java.io.BufferedReader;import java.io.BufferedWriter;import java.io.FileWriter;import java.io.IOException;import java.io.InputStreamReader;import java.io.OutputStreamWriter;import java.net.Socket;public class UserThread implements Runnable { private Socket s; public UserThread(Socket s){ this.s = s; } @Override public void run() { try{ BufferedReader br = new BufferedReader(new InputStreamReader(s.getInputStream())); BufferedWriter bw = new BufferedWriter(new FileWriter(System.currentTimeMillis()+".java")); String line = null; while((line = br.readLine())!=null){ bw.write(line); bw.newLine(); bw.flush(); } BufferedWriter bwServer = new BufferedWriter(new OutputStreamWriter(s.getOutputStream())); bwServer.write("Server收到数据"); bwServer.newLine(); bwServer.flush(); bw.close(); s.close(); }catch(IOException e){ e.printStackTrace(); } }}
转载地址:http://imhkb.baihongyu.com/