全部代码
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;
public class Client {
// 搭建客户端
public static void main(String[] args) throws IOException {
try {
// 1、创建客户端Socket,指定服务器地址和端口
Socket socket=new Socket("127.0.0.1", 5209);
System.out.println("客户端启动成功");
// 2、获取输出流,向服务器端发送信息
// 向本机的5209端口发出客户请求
BufferedReader br = new BufferedReader(
new InputStreamReader(System.in));
// 由系统标准输入设备构造BufferedReader对象
PrintWriter write = new PrintWriter(
socket.getOutputStream());
// 由Socket对象得到输出流,并构造PrintWriter对象
//3、获取输入流,并读取服务器端的响应信息
BufferedReader in = new BufferedReader(
new InputStreamReader(socket.getInputStream()));
// 由Socket对象得到输入流,并构造相应的BufferedReader对象
String readline;
readline = br.readLine(); // 从系统标准输入读入一字符串
while (!readline.equals("end")) {
// 若从标准输入读入的字符串为 "end"则停止循环
write.println(readline);
// 将从系统标准输入读入的字符串输出到Server
write.flush();
String msg = in.readLine();
System.out.println("server:" + msg);
// 从Server读入一字符串,并打印到标准输出上
readline = br.readLine(); // 从系统标准输入读入一字符串
} // 继续循环
//4、关闭资源
write.close(); // 关闭Socket输出流
in.close(); // 关闭Socket输入流
socket.close(); // 关闭Socket
} catch (Exception e) {
// 出错,打印出错信息
System.out.println("can not listen to:" + e);
}
}
}
class Server {
//搭建服务器端
public static void main(String[] args) throws IOException{
//创建一个服务器端Socket,即SocketService
new Server().start();;
}
public void start(){
try{
ServerSocket server=null;
try{
//指定绑定的端口,并监听此端口。
//创建一个ServerSocket在端口5209监听客户请求
server=new ServerSocket(5209);
System.out.println("服务器启动成功");
}catch(Exception e) {
//出错,打印出错信息
System.out.println("没有启动监听:"+e);
}
Socket socket=null;
try{
//调用accept()方法开始监听,等待客户端的连接
//使用accept()阻塞等待客户请求,有客户
//请求到来则产生一个Socket对象,并继续执行
socket=server.accept();
}catch(Exception e) {
//出错,打印出错信息
System.out.println("Error."+e);
}
//3、获取输入流,并读取客户端信息
BufferedReader in=new BufferedReader(
new InputStreamReader(socket.getInputStream()));
//由Socket对象得到输入流,并构造相应的BufferedReader对象
PrintWriter writer=new PrintWriter(socket.getOutputStream());
//由Socket对象得到输出流,并构造PrintWriter对象
String msg = in.readLine();
while (!msg.equals("end")) {
System.out.println("client:" + msg);
writer.println(msg);
writer.flush();
msg = in.readLine();
}
//5、关闭资源
writer.close(); //关闭Socket输出流
in.close(); //关闭Socket输入流
socket.close(); //关闭Socket
server.close(); //关闭ServerSocket
}catch(Exception e) {//出错,打印出错信息
System.out.println("Error."+e);
}
}
}