快捷導(dǎo)航

Java Scoket實(shí)現(xiàn)雙向通信代碼詳解

更新時(shí)間：2020年06月24日 09:39:12 作者：辰兮要努力

這篇文章主要介紹了Java Scoket實(shí)現(xiàn)雙向通信代碼詳解，文中通過示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧

你好我是辰兮，很高興你能來閱讀，本篇總結(jié)了Java Scoket類的相關(guān)知識(shí)，并且整理了實(shí)現(xiàn)雙向通信的相關(guān)代碼也有案例實(shí)現(xiàn)截圖，分享獲取新知，大家一起進(jìn)步。

一、網(wǎng)絡(luò)通信

網(wǎng)絡(luò)通信，在網(wǎng)絡(luò)中程序（發(fā)送者）與程序（接受者）之間的數(shù)據(jù)交互。

通信要素①ip + 端口號(hào) ②傳輸協(xié)議

java.net包: 包含了Java用于網(wǎng)絡(luò)通信所需的類。

ServerSocket類，用于表示網(wǎng)絡(luò)服務(wù)

創(chuàng)建網(wǎng)絡(luò)服務(wù)（創(chuàng)建ServerSocket對(duì)象）

//構(gòu)造器
public ServerSocket(int port)

//創(chuàng)建網(wǎng)絡(luò)服務(wù)
ServerSocket server = new ServerSocket(9999);

接收網(wǎng)絡(luò)請(qǐng)求

//接收網(wǎng)絡(luò)請(qǐng)求的方法
public Socket accept()

//網(wǎng)絡(luò)服務(wù)接收請(qǐng)求（阻塞）
Socket socket = server.accept();

Socket類，網(wǎng)絡(luò)套接字，表示網(wǎng)絡(luò)連接

發(fā)送網(wǎng)絡(luò)請(qǐng)求
//構(gòu)造器
public Socket(String ip, int port)
//獲取網(wǎng)絡(luò)連接中的輸入流
public InputStream getInputStream()
//獲取網(wǎng)絡(luò)連接中的輸出流
public OuputStream getOutputStream()

二、接受者（Receiver）

代碼實(shí)現(xiàn)如下:信息的接受者

public class Receiver {

  public static void main(String[] args) {

    try {
      ServerSocket server = new ServerSocket(8888);
      Socket socket = server.accept();
      System.out.println("----程序已經(jīng)連接++++");
      InputStream is = socket.getInputStream();
      OutputStream os = socket.getOutputStream();
      InputStreamReader isr = new InputStreamReader(is);
      BufferedReader br = new BufferedReader(isr);
      PrintWriter pw = new PrintWriter(os);
      Runnable r1 = new Runnable() {
        @Override
        public void run() {
          while (true) {
            // 接受信息
            String str;
            try {
              str = br.readLine();
              System.out.println("sender的信息" + str);
            } catch (IOException e) {
              e.printStackTrace();
            }
          }
        }
      };
      Runnable r2 = new Runnable() {
        @Override
        public void run() {
          // 返回信息
          while (true) {
            Scanner scan = new Scanner(System.in);
            String msg = scan.nextLine();
            pw.println(msg);
            pw.flush();
          }
        }
      };
      
      Thread t1 = new Thread(r1);
      Thread t2 = new Thread(r2);
      t1.start();
      t2.start();
    } catch (IOException e) {
      e.printStackTrace();
    }
  }
}

三、發(fā)送者(Sender)

代碼實(shí)現(xiàn)如下:信息的發(fā)送者

public class Sender {

  public static void main(String[] args) {
    try {
      Socket socket = new Socket("192.168.1.6", 8888);
      InputStream is = socket.getInputStream();
      OutputStream os = socket.getOutputStream();
      InputStreamReader isr = new InputStreamReader(is);
      BufferedReader br = new BufferedReader(isr);
      PrintWriter pw = new PrintWriter(os);
      Runnable r = new Runnable() {
        @Override
        public void run() {
          while (true) {
            // 發(fā)送信息

            try {
              Scanner scan = new Scanner(System.in);
              String msg = scan.nextLine();
              pw.println(msg);
              pw.flush();
            } catch (Exception e) {
            }

          }

        }
      };

      Runnable r2 = new Runnable() {
        @Override
        public void run() {
          // 接受發(fā)送的信息
          while (true) {
            String str;
            try {
              str = br.readLine();
              System.out.println("接受者receiver:" + str);
            } catch (IOException e) {
              e.printStackTrace();
            }
          }
        }
      };
      Thread t1 = new Thread(r);
      Thread t2 = new Thread(r2);
      t1.start();
      t2.start();

    } catch (UnknownHostException e) {

      e.printStackTrace();
    } catch (IOException e) {

      e.printStackTrace();
    }
  }
}

四、案例截圖

首先看到開啟Receiver，然后開啟Sender

開啟Sender后----看到Receiver控制臺(tái)顯示連接成功