socket通信

it2022-05-05  101

SocketServer类: package com.practice.test; import java.io.IOException; import java.io.OutputStream; import java.net.ServerSocket; import java.net.Socket; public class SocketServer { public static void getSocketServer(){ try { //-------服务器端口 ServerSocket serverSocket=new ServerSocket(8080); //服务器在8080端口接收客户端请求 Socket socket=serverSocket.accept(); //获取请求的输出流 OutputStream os=socket.getOutputStream(); //把内容给输出流输出到客户端 os.write("zhouyajuan".getBytes()); os.close(); socket.close(); serverSocket.close(); } catch (IOException e) { e.printStackTrace(); } } } SocketClient类: package com.practice.test; import java.io.BufferedReader; import java.io.IOException; import java.io.InputStream; import java.io.InputStreamReader; import java.net.Socket; public class SocketClient { public static void getSocketClient(){ try { //和服务器端建立联系 Socket socket=new Socket("127.0.0.1",8080); //获取服务器端输入流 InputStream in=socket.getInputStream(); //把输入流转成可读的字节流 BufferedReader br=new BufferedReader(new InputStreamReader(in)); //读取服务器端的输入流 String line=null; while((line=br.readLine())!=null){ //输出服务器端传过来的内容 System.out.println(line); } in.close(); socket.close(); } catch (IOException e) { e.printStackTrace(); } } } Test服务器端启动类: package com.practice.test; public class Test { public static void main(String[] args) { SocketServer socketServer=null; //SocketClient socketClient=null; socketServer.getSocketServer(); System.out.println("服务端启动了=============================================="); //socketClient.getSocketClient(); } } Test1客户端启动类: package com.practice.test; public class Test1 { public static void main(String[] args) { //SocketServer socketServer=null; SocketClient socketClient=null; // socketServer.getSocketServer(); socketClient.getSocketClient(); System.out.println("客户端启动了=============================================="); } }

先动服务器端,再启动客户端。


最新回复(0)