Java中使用Socket实现服务器端和客户端通讯

时间：2023-03-08 17:39:56
Java中使用Socket实现服务器端和客户端通讯

创建服务器端serverSocket

 import java.io.BufferedReader;

 import java.io.IOException;

 import java.io.InputStream;

 import java.io.InputStreamReader;

 import java.io.OutputStream;

 import java.io.PrintWriter;

 import java.net.ServerSocket;

 import java.net.Socket;

 /**

  * 服务端

  * @author Administrator

  *

  */

 public class Server {

     public static void main(String[] args) throws IOException {

         //创建一个服务器端socket，指定绑定的端口号，并监听此端口

         ServerSocket serverSocket = new ServerSocket(8888);

         //调用accept()方法开始监听，等待客户端的连接

         System.out.println("**********服务器即将启动，等待客户端的连接*************");

         Socket socket = serverSocket.accept();

         //获取输入流，并读取客户端信息

         InputStream inp = socket.getInputStream();

         //把字节流转换成字符流

         InputStreamReader isr = new InputStreamReader(inp);

         //为字符流增加缓冲区

         BufferedReader bfr = new BufferedReader(isr);

         String info = null;

         while((info=bfr.readLine())!=null){//循环读取数据

             System.out.println("我是服务器，客户端说："+info);

         }

         socket.shutdownInput();//关闭输入流

         //向客户端传递的信息

         OutputStream ots = socket.getOutputStream();

         PrintWriter pw = new PrintWriter(ots);

         pw.write("欢迎登陆");

         pw.flush();

         //关闭资源

         pw.close();

         ots.close();

         bfr.close();

         isr.close();

         inp.close();

         socket.close();

         serverSocket.close();

     }

 }

创建客户端socket

 import java.io.BufferedReader;

 import java.io.IOException;

 import java.io.InputStream;

 import java.io.InputStreamReader;

 import java.io.OutputStream;

 import java.io.PrintWriter;

 import java.net.Socket;

 import java.net.UnknownHostException;

 /**

  * 客户端

  * @author Administrator

  *

  */

 public class Client {

     public static void main(String[] args) {

         try {

             //创建一个客户端socket

             Socket socket = new Socket("localhost",8888);

             //向服务器端传递信息

             OutputStream ots = socket.getOutputStream();

             PrintWriter pw = new PrintWriter(ots);

             pw.write("用户名：admin;密码：123");

             pw.flush();

             //关闭输出流

             socket.shutdownOutput();

             //获取服务器端传递的数据

             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);

             }

             //关闭资源

             br.close();

             isr.close();

             is.close();

             pw.close();

             ots.close();

             socket.close();

         } catch (UnknownHostException e) {

             e.printStackTrace();

         } catch (IOException e) {

             e.printStackTrace();

         }

     }

 }

先启动服务器端，再启动客户端

服务器端打印结果为

**********服务器即将启动，等待客户端的连接*************

我是服务器，客户端说：用户名：admin;密码：123

客户端打印结果

我是客户端，服务器说：欢迎登陆

相关文章