客户端
复制代码代码如下 :
import java.io.bufferedReader;
import java.io.inputStreamReader;
import java.io.printwriter;
import java.net.socket;
공개 클래스 myclient {
public static void main (string [] args)은 예외 {
소켓 소켓 = 새로운 소켓 ( "로컬 호스트", 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 ();
}
}
服务端
复制代码代码如下 :
import java.io.bufferedReader;
import java.io.ioexception;
import java.io.inputStreamReader;
import java.io.printwriter;
import java.net.serversocket;
import java.net.socket;
공개 클래스 MyServer {
public static void main (String [] args)은 ioexception {
Serversocket Server = New Serversocket (10000);
while (true) {
Socket Socket = Server.accept ();
호출 (소켓);
}
}
개인 정적 무효 호출 (최종 소켓 클라이언트)이 IoException {
새 스레드 (new runnable () {
public void run () {
버퍼드 리더 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 ();
} 마지막으로 {
노력하다 {
넣다();
} catch (예외 e) {}
노력하다 {
out.close ();
} catch (예외 e) {}
노력하다 {
client.close ();
} catch (예외 E) {}
}
}
}).시작();
}
}