Java如何實(shí)現(xiàn)TCP/IP協(xié)議的收發(fā)數(shù)據(jù)服務(wù)端

小編給大家分享一下Java如何實(shí)現(xiàn)TCP/IP協(xié)議的收發(fā)數(shù)據(jù)服務(wù)端，相信大部分人都還不怎么了解，因此分享這篇文章給大家參考一下，希望大家閱讀完這篇文章后大有收獲，下面讓我們一起去了解一下吧！

功能如下：

注：

只有服務(wù)端，沒(méi)有客戶(hù)端，測(cè)試時(shí)采用第三方軟件作為客戶(hù)端的。

收發(fā)數(shù)據(jù)目前能正常收發(fā)數(shù)據(jù)，只是中文的會(huì)變成亂碼顯示。

采用Thread類(lèi)實(shí)現(xiàn)一個(gè)收發(fā)數(shù)據(jù)的線程。

服務(wù)端代碼：

import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.ServerSocket;
import java.net.Socket;

public class Server {
  //監(jiān)聽(tīng)端口
  private static final int PORT = 60020;

  public static void main(String[] args) throws IOException {
    ServerSocket serverSocket = null;
    Socket socket = null;
    try {
      //建立服務(wù)器的Socket，并設(shè)定一個(gè)監(jiān)聽(tīng)的端口PORT
      serverSocket = new ServerSocket(PORT);
      //由于需要進(jìn)行循環(huán)監(jiān)聽(tīng)，因此獲取消息的操作應(yīng)放在一個(gè)while大循環(huán)中
      while(true){
         try {
          //建立跟客戶(hù)端的連接
          socket = serverSocket.accept();
         } catch (Exception e) {
           System.out.println("建立與客戶(hù)端的連接出現(xiàn)異常");
           e.printStackTrace();
         }
         ServerThread thread = new ServerThread(socket);
         thread.start();
      }
    } catch (Exception e) {
      System.out.println("端口被占用");
      e.printStackTrace();
    }    
    finally {
      serverSocket.close();
    }
  }
}

//服務(wù)端線程類(lèi)
//繼承Thread類(lèi)的話(huà)，必須重寫(xiě)run方法，在run方法中定義需要執(zhí)行的任務(wù)。
class ServerThread extends Thread {
  private Socket socket ;
  InputStream inputStream;
  OutputStream outputStream;
  
  public ServerThread(Socket socket){
    this.socket=socket;
  }
  public void run(){
    try {
      while (true){
        //接收客戶(hù)端的消息并打印
        System.out.println(socket);
        inputStream=socket.getInputStream();
        byte[] bytes = new byte[1024];
        inputStream.read(bytes);
        String string = new String(bytes);
        System.out.println(string);  
        
        //向客戶(hù)端發(fā)送消息
        outputStream = socket.getOutputStream();
        outputStream.write("OK".getBytes());
        System.out.println("OK");
        
      }
    } catch (Exception e) {
      System.out.println("客戶(hù)端主動(dòng)斷開(kāi)連接了");
      //e.printStackTrace();
    }
    //操作結(jié)束，關(guān)閉socket
    try{
      socket.close(); 
    }catch(IOException e){
      System.out.println("關(guān)閉連接出現(xiàn)異常");  
      e.printStackTrace();
    }
  }
}

先開(kāi)啟服務(wù)端，再開(kāi)啟客戶(hù)端，進(jìn)行操作。

客戶(hù)端：

（端口號(hào)選擇“TCPClient”，遠(yuǎn)程填寫(xiě)IP地址和程序里設(shè)定好的端口“60020”，本地選擇自己電腦的IP地址）

服務(wù)端：

以上是“Java如何實(shí)現(xiàn)TCP/IP協(xié)議的收發(fā)數(shù)據(jù)服務(wù)端”這篇文章的所有內(nèi)容，感謝各位的閱讀！相信大家都有了一定的了解，希望分享的內(nèi)容對(duì)大家有所幫助，如果還想學(xué)習(xí)更多知識(shí)，歡迎關(guān)注億速云行業(yè)資訊頻道！