客户端
复制代码代码如下:
导入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){}
}
}
})。开始();
}
}