import java.net.*;
import java.io.*;
public class MyQQServer {
/**
* @param args
*/
public static void main(String[] args) throws Exception {
ServerSocket server=new ServerSocket(5678);
System.out.println("服务器已启动,请启动客户端");
Socket client=server.accept();
BufferedReader in=new BufferedReader(new InputStreamReader(client.getInputStream()));
PrintWriter out=new PrintWriter(client.getOutputStream());
while (true) {
String content=in.readLine();
System.out.println("收到消息:" + content);
BufferedReader wt=new BufferedReader(new InputStreamReader(System.in));
out.println(wt.readLine());
//out.println("message from server:has received your message \"" + content + "\"" );
out.flush();
if (content.equals("quit")) {
System.out.println("客户端已经退出此次会话..");
break;
}
}
client.close();
server.close();
}
}
- 1
- 2
前往页