本文共 1995 字,大约阅读时间需要 6 分钟。
大致流程:
建立连接:服务器端建立ServerSocket绑定指定端口等待连接
客户端建立Socket向服务端发送请求
服务端接受后创建连接Socket
开始通信:通过输入流和输出流进行数据交换
关闭Socket及相关资源
/* * 服务器端 */public class Server { public static void main(String[] args) { try { //1.创建服务器端socket。即ServerSocket,指定绑定的端口,并监听此端口 ServerSocket serverSocket = new ServerSocket(8888); //2.调用accept()方法开始监听,等待客户端的连接 System.out.println("***服务器即将启动,等待客户端的连接***"); Socket socket = serverSocket.accept(); //3.获取输入流,并读取客户端信息 InputStream is = socket.getInputStream();//字节输入流 InputStreamReader isr = new InputStreamReader(is);//将字节流转换为字符流提高性能 BufferedReader br = new BufferedReader(isr); String info = null; while((info=br.readLine())!=null) { System.out.println("我是服务器,客户端说:"+info); } socket.shutdownInput(); //获取输出流,响应客户端请求 OutputStream os = socket.getOutputStream(); PrintWriter pw = new PrintWriter(os); pw.write("欢迎您!"); pw.flush();//刷新缓存 socket.shutdownOutput(); //5.关闭相关资源 pw.close(); os.close(); br.close(); isr.close(); is.close(); socket.close(); serverSocket.close(); } catch (IOException e) { e.printStackTrace(); } }}
/* * 基于TCP协议的Socket通信,实现用户登录 * 客户端 */public class Client { public static void main(String[] args) { try { //1.创建客户端Socket,指定服务器地址和端口 Socket socket = new Socket("localhost",8888); //2.获取输出流。想服务端发送信息 OutputStream os = socket.getOutputStream();//字节输出流 PrintWriter pw = new PrintWriter(os);//将输出流包装成打印流 pw.write("用户名:admin;密码:123"); pw.flush(); socket.shutdownOutput(); //3.获取输入流,读取服务端响应 InputStream is = socket.getInputStream(); BufferedReader br = new BufferedReader(new InputStreamReader(is)); String info = null; while((info=br.readLine())!=null) { System.out.println("我是客户端,服务端说:"+info); } socket.shutdownInput(); //4.关闭资源 br.close(); is.close(); pw.close(); os.close(); socket.close(); } catch (UnknownHostException e) { e.printStackTrace(); } catch (IOException e) { e.printStackTrace(); } }}
服务端:
客户端:
转载地址:http://vwprn.baihongyu.com/