客户端
复制代码代码如下:
Импорт java.io.bufferedReader;
Импорт java.io.inputStreamReader;
Импорт java.io.printwriter;
импортировать java.net.socket;
открытый класс myclient {
public static void main (string [] args) бросает исключение {
Сокет сокет = новый сокет ("Localhost", 10000);
BufferedReader in = new BufferedReader (новый inputStreamReader (socket.getInputStream ()));
Printwriter out = new PrintWriter (socket.getOutputStream ());
BufferedReader Reader = New BufferedReader (New InputStreamReader (System.in));
while (true) {
String 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) бросает ioException {
Serversocket Server = New Serversocket (10000);
while (true) {
Сокет сокет = server.accept ();
вызвать (сокет);
}
}
private static void invoke (Final Socket Client) бросает ioException {
Новый поток (new Runnable () {
public void run () {
BufferedReader in = null;
Printwriter Out = null;
пытаться {
in = new BufferedReader (новый inputStreamReader (client.getInputStream ()));
out = new PrintWriter (client.getOutputStream ());
while (true) {
String msg = in.readline ();
System.out.println (MSG);
out.println ("сервер получен" + msg);
out.flush ();
if (msg.equals ("bye")) {
перерыв;
}
}
} catch (ioException ex) {
ex.printstacktrace ();
} окончательно {
пытаться {
in.close ();
} catch (Exception e) {}
пытаться {
out.close ();
} catch (Exception e) {}
пытаться {
client.close ();
} catch (Exception e) {}
}
}
}).начинать();
}
}