中文字幕av专区_日韩电影在线播放_精品国产精品久久一区免费式_av在线免费观看网站

溫馨提示×

溫馨提示×

您好,登錄后才能下訂單哦!

密碼登錄×
登錄注冊×
其他方式登錄
點擊 登錄注冊 即表示同意《億速云用戶服務條款》

使用java如何實現基于TCP協議網絡socket編程

發布時間:2020-10-31 01:23:16 來源:億速云 閱讀:295 作者:Leah 欄目:開發技術

使用java如何實現基于TCP協議網絡socket編程?針對這個問題,這篇文章詳細介紹了相對應的分析和解答,希望可以幫助更多想解決這個問題的小伙伴找到更簡單易行的方法。

一、前言:TCP原理簡介

首先,保證文章完整性,TCP的理論原理還是需要簡介一下,略顯枯燥๑乛◡乛๑。

TCP(傳輸控制協議,Transmission Control Protocol)是一種面向連接的、可靠的、基于字節流的傳輸層通信協議。TCP旨在適應支持多網絡應用的分層協議層次結構。也就是說,TCP是為了在不可靠的互聯網絡上提供可靠的端到端字節流而專門設計的一個傳輸協議。 連接到不同但互連的計算機通信網絡的主計算機中的成對進程之間依靠TCP提供可靠的通信服務。

以上TCP的特點,也正是與UDP的明顯不同之處。UDP(用戶數據報協議)是一種無連接的、不可靠的、不以字節流傳輸通信協議。具體區別可對比之前這篇文章:

【基于UDP協議網絡Socket編程(java實現C/S通信案例) 】 [https://www.jb51.net/article/198498.htm]

接著,“三次握手”則是眾所周知的一個詞,是建立TCP連接的重要過程。許多文章有詳細解讀,本篇則是詳細記錄在此原理之上,使用Java實現TCP的Socket網絡通信,包含C/S軟件架構的程序設計,偏向實踐,更加有趣!

使用java如何實現基于TCP協議網絡socket編程

二、Socket編程通信

本篇使用Java進行Socket編程,Java的TCP/IP套接字編程將底層的細節進行了封裝,其編程模型如圖:

使用java如何實現基于TCP協議網絡socket編程

我們自頂向下觀察,基于TCP的通信,必然有服務端Server和客戶端Client。

首先,建立連接。兩端分別有一個套接字Socket,用于兩者之間的通信。客戶端向服務器發送請求,創建socket進行連接。服務端則隨時監聽客戶端發起的請求,接收并創建裂解Socket。

其次,開始通信。服務和客戶兩端的輸入輸出流互相通信。邏輯上可理解為通信進程的雙方具有兩個流(輸出流和輸入流)。邏輯上可將兩個流理解為兩個通信管道的全雙工通信模式,一個用于向對方發送數據,另一個用于接收對方的數據。

最后,結束通信。客戶端訪問服務器結束,斷開連接,關閉Socket和相關資源(輸入輸出流等)。服務端監聽客戶端狀態,同時關閉Socket等連接。

建立通信規則:

Server和Client之間需要約定相同的規則,保證正常通信。之后的程序設計,我們約定:

客戶端連接服務器,連接成功后,服務器首先給客戶端發送一條歡迎信息;

客戶端程序每發送一條信息給服務器,服務器接收并回送該信息到客戶端,客戶端接收并顯示該信息;

當客戶端發送"bye",則結束對話。

三、TCP服務器端(具體代碼)

第一步,創建服務端套接字。

類成員變量:ServerSocket serverSocket,監聽端口號port;

  private int port =8008;//服務器監聽窗口
  private ServerSocket serverSocket;//定義服務器套接字

  public TCPServer() throws IOException{
    serverSocket =new ServerSocket(port);
    System.out.println("服務器啟動監聽在"+port+"端口...");

  }

第二步,定義輸入輸出流方法:

 private PrintWriter getWriter(Socket socket) throws IOException{
    //獲得輸出流緩沖區的地址
    OutputStream socketOut=socket.getOutputStream();
    //網絡流寫出需要使用flush,這里在printWriter構造方法直接設置為自動flush
    return new PrintWriter(new OutputStreamWriter(socketOut,"utf-8"),true);
  }

  private BufferedReader getReader(Socket socket) throws IOException{
    //獲得輸入流緩沖區的地址
    InputStream socketIn=socket.getInputStream();
    return new BufferedReader(new InputStreamReader(socketIn,"utf-8"));
  }

 第三步,服務端核心:

//單客戶版本,每次只能與一個用戶建立通信連接
public void Service(){
  while (true){
    Socket socket=null;
    try {
      //此處程序阻塞,監聽并等待用戶發起連接,有連接請求就生成一個套接字
      socket=serverSocket.accept();

      //本地服務器控制臺顯示客戶連接的用戶信息
      System.out.println("New connection accepted:"+socket.getInetAddress());
      BufferedReader br=getReader(socket);//字符串輸入流
      PrintWriter pw=getWriter(socket);//字符串輸出流
      pw.println("來自服務器消息:歡迎使用本服務!");

      String msg=null;
      //此處程序阻塞,每次從輸入流中讀入一行字符串
      while ((msg=br.readLine())!=null){
        //如果用戶發送信息為”bye“,就結束通信
        if(msg.equals("bye")){
          pw.println("來自服務器消息:服務器斷開連接,結束服務!");
          System.out.println("客戶端離開。");
          break;
        }
        pw.println("來自服務器消息:"+msg);
      }
    }catch (IOException e){
      e.printStackTrace();
    }finally {
      try {
        if (socket!=null)
          socket.close();//關閉socket連接以及相關的輸入輸出流
      }catch (IOException e){
        e.printStackTrace();
      }
    }
  }
}

 代碼關鍵解析很清楚易懂。可以看到,服務端提供服務放到了一個While(true)里面,這是因為服務器程序需要一直運行,所以處理代碼一般放在while(true)這種無限循環中,TCPServer運行一次,且自身不能終止運行,要終止它運行,只能通過強制方式(如在IDE環境強制關閉)。

四、TCP客戶端(具體代碼)

第一步,創建客戶端套接字,定義類構造方法,實現輸入輸出流。

//單客戶版本,每次只能與一個用戶建立通信連接
public void Service(){
  while (true){
    Socket socket=null;
    try {
      //此處程序阻塞,監聽并等待用戶發起連接,有連接請求就生成一個套接字
      socket=serverSocket.accept();

      //本地服務器控制臺顯示客戶連接的用戶信息
      System.out.println("New connection accepted:"+socket.getInetAddress());
      BufferedReader br=getReader(socket);//字符串輸入流
      PrintWriter pw=getWriter(socket);//字符串輸出流
      pw.println("來自服務器消息:歡迎使用本服務!");

      String msg=null;
      //此處程序阻塞,每次從輸入流中讀入一行字符串
      while ((msg=br.readLine())!=null){
        //如果用戶發送信息為”bye“,就結束通信
        if(msg.equals("bye")){
          pw.println("來自服務器消息:服務器斷開連接,結束服務!");
          System.out.println("客戶端離開。");
          break;
        }
        pw.println("來自服務器消息:"+msg);
      }
    }catch (IOException e){
      e.printStackTrace();
    }finally {
      try {
        if (socket!=null)
          socket.close();//關閉socket連接以及相關的輸入輸出流
      }catch (IOException e){
        e.printStackTrace();
      }
    }
  }
}

第二步,實現網絡通信發送和接收方法。

  public void send(String msg){
    //輸出字符流,由socket調用系統底層函數,經網卡發送字節流
    pw.println(msg);
  }

  public String receive(){
    String msg=null;
    try {
      //從網絡輸入字符流中讀取信息,每次只能接受一行信息
      //不夠一行時(無行結束符),該語句阻塞
      //直到條件滿足,程序往下運行
      msg=br.readLine();
    }catch (IOException e){
      e.printStackTrace();
    }
    return msg;
  }

 第三步,定義網絡連接關閉方法供外部調用。

 public void close(){
    try {
      if (socket!=null)
        socket.close();
    }catch (IOException e){
      e.printStackTrace();
    }
  }

TCP連接的釋放也有“四次握手”一說,必須經過2MSL后才真正釋放。具體過程如下圖:

使用java如何實現基于TCP協議網絡socket編程

五、通信效果演示

使用java如何實現基于TCP協議網絡socket編程

GIF動圖演示:

使用java如何實現基于TCP協議網絡socket編程

六、“創意”機器人:價值一個億的AI核心代碼(具體代碼)

這部分我們要實現“聊天機器人”,效果這樣:

使用java如何實現基于TCP協議網絡socket編程

是不是迫不及待想知道如何實現呢!堪稱“價值一個億的AI核心代碼”!!??

就這樣實現了!

使用java如何實現基于TCP協議網絡socket編程

 不賣關子了,就一行代碼!

msg=msg.replace("?","!").replace("?","!").replace("嗎","").replace("嗎?","");

關于使用java如何實現基于TCP協議網絡socket編程問題的解答就分享到這里了,希望以上內容可以對大家有一定的幫助,如果你還有很多疑惑沒有解開,可以關注億速云行業資訊頻道了解更多相關知識。

向AI問一下細節

免責聲明:本站發布的內容(圖片、視頻和文字)以原創、轉載和分享為主,文章觀點不代表本網站立場,如果涉及侵權請聯系站長郵箱:is@yisu.com進行舉報,并提供相關證據,一經查實,將立刻刪除涉嫌侵權內容。

AI

元谋县| 武冈市| 大兴区| 铅山县| 西和县| 通江县| 济南市| 布拖县| 垦利县| 双桥区| 镇赉县| 凌海市| 龙门县| 密云县| 贵溪市| 体育| 东平县| 呈贡县| 河津市| 武宣县| 寿阳县| 弋阳县| 余庆县| 宜兰县| 蓝田县| 山丹县| 石阡县| 当涂县| 高青县| 牡丹江市| 宁化县| 枞阳县| 舟曲县| 罗源县| 房山区| 咸丰县| 松江区| 通江县| 静乐县| 漳州市| 石棉县|