服务器端
|
public class TcpServer { public static void main(String[] args) throws Exception { ServerSocket ss = new
ServerSocket(5000); while(true) { Socket socket = ss.accept(); new ServerInputThread(socket).start(); new ServerOutputThread(socket).start(); } } } |
客户端
|
public class TcpClient { public static void main(String[] args) throws Exception { Socket socket = new Socket("127.0.0.1", 5000); new ClientInputThread(socket).start(); new ClientOutputThread(socket).start(); } } |
服务器端读数据
|
public class ServerInputThread extends Thread { private Socket socket; public ServerInputThread(Socket
socket) { this.socket = socket; } @Override public void run() { try { InputStream is = socket.getInputStream(); while (true) { byte[] buffer = new byte[1024]; int len = is.read(buffer); String str = new String(buffer,
0, len); System.out.println(str); } } catch (IOException e) { // TODO Auto-generated catch block e.printStackTrace(); } } } |
服务器端写数据
|
public class ServerOutputThread extends Thread { private Socket socket; public ServerOutputThread(Socket
socket) { this.socket = socket; } @Override public void run() { try { OutputStream os = socket.getOutputStream(); while (true) { BufferedReader br = new BufferedReader(new
InputStreamReader( System.in)); String line = br.readLine(); os.write(line.getBytes()); } } catch (IOException e) { // TODO Auto-generated catch block e.printStackTrace(); } } } |
客户端读数据
|
public class ClientInputThread extends Thread { private Socket socket; public ClientInputThread(Socket
socket) { this.socket = socket; } @Override public void run() { try { InputStream is = socket.getInputStream(); while (true) { byte[] buffer = new byte[1024]; int len = is.read(buffer); String str = new String(buffer,
0, len); System.out.println(str); } } catch (IOException e) { // TODO Auto-generated catch block e.printStackTrace(); } } } |
客户端写数据
|
public class ClientOutputThread extends Thread { private Socket socket; public ClientOutputThread(Socket
socket) { this.socket = socket; } @Override public void run() { try { OutputStream os = socket.getOutputStream(); while (true) { BufferedReader br = new BufferedReader(new
InputStreamReader( System.in)); String line = br.readLine(); os.write(line.getBytes()); } } catch (IOException e) { // TODO Auto-generated catch block e.printStackTrace(); } } } |