客户端
复制代码代码如下:
java.io.bufferedreaderをインポートします。
java.io.inputStreamReaderをインポートします。
java.io.printwriterをインポートします。
java.net.socketをインポートします。
パブリッククラスmyclient {
public static void main(string [] args)スロー例外{
ソケットソケット= new Socket( "localhost"、10000);
BufferedReader in = new BufferedReader(new inputStreamReader(socket.getInputStream()));
printwriter out = new PrintWriter(socket.getOutputStream());
BufferedReader Reader = new BufferedReader(new inputStreamReader(system.in));
while(true){
文字列msg = reader.readline();
out.println(msg);
out.flush();
if(msg.equals( "bye")){
壊す;
}
system.out.println(in.readline());
}
socket.close();
}
}
服务端
复制代码代码如下:
java.io.bufferedreaderをインポートします。
java.io.ioexceptionをインポートします。
java.io.inputStreamReaderをインポートします。
java.io.printwriterをインポートします。
java.net.serversocketをインポートします。
java.net.socketをインポートします。
パブリッククラスMyServer {
public static void main(string [] args)throws ioexception {
Serversocket Server = new Serversocket(10000);
while(true){
SocketSocket = server.accept();
Invoke(socket);
}
}
private static 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());
while(true){
文字列msg = in.readline();
System.out.println(msg);
out.println( "サーバー受信" + msg);
out.flush();
if(msg.equals( "bye")){
壊す;
}
}
} catch(ioException ex){
ex.printstacktrace();
} ついに {
試す {
in.close();
} catch(例外e){}
試す {
out.close();
} catch(例外e){}
試す {
client.close();
} catch(例外e){}
}
}
})。始める();
}
}