package socket;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 SocketService {//搭建服务器端public static void main(String[] args) throws IOException{SocketService socketService = new SocketService();//1、a)创建一个服务器端Socket，即SocketService
        socketService.oneServer();}public  void oneServer(){try{ServerSocket server=null;try{server=new ServerSocket(5209);//b)指定绑定的端口，并监听此端口。System.out.println("服务器启动成功");//创建一个ServerSocket在端口5209监听客户请求}catch(Exception e) {System.out.println("没有启动监听："+e);//出错，打印出错信息
            }Socket socket=null;try{socket=server.accept();//2、调用accept()方法开始监听，等待客户端的连接 //使用accept()阻塞等待客户请求，有客户//请求到来则产生一个Socket对象，并继续执行}catch(Exception e) {System.out.println("Error."+e);//出错，打印出错信息
            }//3、获取输入流，并读取客户端信息
            String line;BufferedReader in=new BufferedReader(new InputStreamReader(socket.getInputStream()));//由Socket对象得到输入流，并构造相应的BufferedReader对象PrintWriter writer=new PrintWriter(socket.getOutputStream());//由Socket对象得到输出流，并构造PrintWriter对象BufferedReader br=new BufferedReader(new InputStreamReader(System.in));//由系统标准输入设备构造BufferedReader对象System.out.println("Client:"+in.readLine());//在标准输出上打印从客户端读入的字符串line=in.readLine();
//            line=br.readLine();//从标准输入读入一字符串//4、获取输出流，响应客户端的请求 while(!line.equals("end")){//如果该字符串为 "bye"，则停止循环//              writer.println(line);//向客户端输出该字符串//               writer.flush();//刷新输出流，使Client马上收到该字符串//               System.out.println("Server:"+line);//在系统标准输出上打印读入的字符串System.out.println("Client:"+in.readLine());//从Client读入一字符串，并打印到标准输出上//            line=br.readLine();//从系统标准输入读入一字符串} //继续循环//5、关闭资源 writer.close(); //关闭Socket输出流in.close(); //关闭Socket输入流socket.close(); //关闭Socketserver.close(); //关闭ServerSocket}catch(Exception e) {//出错，打印出错信息System.out.println("Error."+e);}}
}

package socket;import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.InetAddress;
import java.net.Socket;
import java.net.URL;public class SocketClient {// 搭建客户端public static void main(String[] args) throws IOException {try {// 1、创建客户端Socket，指定服务器地址和端口// Socket socket=new Socket("127.0.0.1",5200);Socket socket = new Socket("127.0.0.1", 5209);System.out.println("客户端启动成功");// 2、获取输出流，向服务器端发送信息// 向本机的52000端口发出客户请求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();// 刷新输出流，使Server马上收到该字符串System.out.println("Client:" + readline);// 在系统标准输出上打印读入的字符串//              System.out.println("Server:" + in.readLine());// 从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);// 出错，打印出错信息
        }}}