客戶端
複製代碼代碼如下:
導入java.io..bufferedreader;
導入java.io.io.inputStreamReader;
導入java.io..printwriter;
導入java.net.socket;
公共類myclient {
public static void main(string [] args)拋出異常{
套接字插座=新套接字(“ Localhost”,10000);
BufferedReader in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
printWriter out = new printWriter(socket.getOutputstream());
BufferedReader Reader = new BufferedReader(new InputStreamReader(System.in));
而(true){
字符串msg = reader.readline();
out.println(msg);
out.flush();
如果(msg.equals(“ bye”)){
休息;
}
system.out.println(in.Readline());
}
socket.Close();
}
}
服務端
複製代碼代碼如下:
導入java.io..bufferedreader;
導入java.io.ioexception;
導入java.io.io.inputStreamReader;
導入java.io..printwriter;
導入java.net.serversocket;
導入java.net.socket;
公共類Myserver {
公共靜態void main(string [] args)拋出ioexception {
serversocket Server = new serversocket(10000);
而(true){
插座套接字= server.accept();
調用(插座);
}
}
私有靜態void Invoke(最終插座客戶端)拋出ioexception {
新線程(new runnable(){
public void run(){
bufferedReader in = null;
printwriter out = null;
嘗試 {
in = new BufferedReader(new InputStreamReader(client.getInputStream()));
out = new printWriter(client.getOutputStream());
而(true){
字符串msg = in.Readline();
system.out.println(msg);
out.println(“接收到的服務器” + msg);
out.flush();
如果(msg.equals(“ bye”)){
休息;
}
}
} catch(ioexception ex){
ex.printstacktrace();
} 最後 {
嘗試 {
附寄();
} catch(異常E){}
嘗試 {
out.close();
} catch(異常E){}
嘗試 {
client.close();
} catch(異常E){}
}
}
})。開始();
}
}