加入星計(jì)劃,您可以享受以下權(quán)益:

  • 創(chuàng)作內(nèi)容快速變現(xiàn)
  • 行業(yè)影響力擴(kuò)散
  • 作品版權(quán)保護(hù)
  • 300W+ 專(zhuān)業(yè)用戶(hù)
  • 1.5W+ 優(yōu)質(zhì)創(chuàng)作者
  • 5000+ 長(zhǎng)期合作伙伴
立即加入
  • 正文
  • 相關(guān)推薦
  • 電子產(chǎn)業(yè)圖譜
申請(qǐng)入駐 產(chǎn)業(yè)圖譜

實(shí)操 | 手把手教你 Socket 通信(TCPIP)

2021/08/05
281
閱讀需 12 分鐘
加入交流群
掃碼加入
獲取工程師必備禮包
參與熱點(diǎn)資訊討論

網(wǎng)絡(luò)上的兩個(gè)程序通過(guò)一個(gè)雙向的通信連接實(shí)現(xiàn)數(shù)據(jù)的交換,這個(gè)連接的一端稱(chēng)為一個(gè)socket。

建立網(wǎng)絡(luò)通信連接至少要一對(duì)端口號(hào)(socket)。socket 本質(zhì)是編程接口(API),對(duì)TCP/IP的封裝,TCP/IP也要提供可供程序員做網(wǎng)絡(luò)開(kāi)發(fā)所用的接口,這就是Socket編程接口;HTTP是轎車(chē),提供了封裝或者顯示數(shù)據(jù)的具體形式;Socket是發(fā)動(dòng)機(jī),提供了網(wǎng)絡(luò)通信的能力。

下載eclipse:https://www.eclipse.org/

本文將給出完整 Socket 通信代碼,在 eclipse 中親測(cè)有效。在Android Studio中用Java開(kāi)發(fā)也是一樣的,只是把代碼和控件搭配一下,注冊(cè)監(jiān)聽(tīng)就好。區(qū)別就是在 AS 中 import 的聲明不太一樣,然后窗口不需要自己建立。

效果如圖

在eclipse中,F(xiàn)ile→New→Java Project→起個(gè)英文名字→Finish(我起的名字是TCP)

目錄結(jié)構(gòu):

 

新建完以后有個(gè)src默認(rèn)包,右鍵 src→New→Package→ 輸入 com.net(因?yàn)槌绦蚶镂矣玫陌拿质沁@個(gè),你可以同時(shí)兩個(gè)一起改)→ Finish

然后右鍵 com.net → New → Class → 輸入 TCPClient(因?yàn)槲页绦蚶锩嬗玫倪@個(gè)類(lèi)名稱(chēng))

然后右鍵 com.net → New → Class → 輸入 TCPServer(因?yàn)槲页绦蚶锩嬗玫倪@個(gè)類(lèi)名稱(chēng))

兩個(gè)里面分別粘貼代碼:

TCPServer

package com.net;

import java.io.*;
import java.net.*;
import java.awt.*;
import java.awt.event.*;

public class TCPServer {
 static DataInputStream dis=null;
 public static void main(String[] args){
  boolean started=false;
  Socket s=null;
  TextArea ta=new TextArea();
  ta.append("從客戶(hù)端接受的數(shù)據(jù):"+"n");
  ServerSocket ss=null;
  try{
   ss=new ServerSocket(8866);                       //端口號(hào)
  }catch(BindException e){
   System.exit(0);
  }catch(IOException e){
   e.printStackTrace();
  }
  Frame f=new Frame("服務(wù)器端");              //窗體名稱(chēng) 
  f.setLocation(300, 300);           //窗體出現(xiàn)位置
  f.setSize(200, 200);            //窗體大小
  f.add(ta,BorderLayout.NORTH);
  f.pack();
  f.addWindowListener(new WindowAdapter(){
   public void windowClosing(WindowEvent e){
    System.exit(0);
   }
  });
  f.setVisible(true);
  try{               //try-catch塊捕捉異常
   started=true;
   while(started){
    boolean bConnected=false;
    s=ss.accept();
    bConnected=true;
    dis=new DataInputStream(s.getInputStream());
    while(bConnected){
        String str=dis.readUTF();
        ta.append(str+"n");
    }
   }
  }catch(EOFException e){                                 
   System.out.println("Client closed!");
  }catch(IOException e){
   e.printStackTrace();
  }finally{
   try{
    if(dis!=null)
     dis.close();
    if(s!=null)
     s.close();
   }catch(Exception e){
    e.printStackTrace();
   }
  }
 }
}

TCPClient

package com.net;
import java.awt.*;
import java.awt.event.*;
import java.io.*;
import java.net.*;

public class TCPClient extends Frame{
 Socket s=null;
 DataOutputStream dos=null;
 DataInputStream  dis=null;
 TextField tf=new TextField(40);
 List list=new List(6);
 public static void main(String[] args){
  TCPClient client=new TCPClient();
  client.list.add("向服務(wù)器端發(fā)送的數(shù)據(jù):");
  client.setTitle("客戶(hù)端");
  client.run();
 }
 public void run(){
  setLocation(400,300);
  this.setSize(300, 300);
  add(tf,BorderLayout.SOUTH);
  add(list,BorderLayout.NORTH);
  pack();
  this.addWindowListener(new WindowAdapter(){
   public void windowClosing(WindowEvent e){
    disconnect();
    System.exit(0);
   }
  });
  tf.addActionListener(new MyListener());
  setVisible(true);
  connect();
 }
public void connect(){
 try{
  s=new Socket("127.0.0.1",8866);
  dos=new DataOutputStream(s.getOutputStream());
 }catch(UnknownHostException e){
  e.printStackTrace();
 }catch(IOException e){
  e.printStackTrace();
 }
}
public void disconnect(){
 try{
  dos.close();
  s.close();
 }catch(IOException e){
  e.printStackTrace();
 }
}
private class MyListener implements ActionListener{
    public void actionPerformed(ActionEvent e){
      String s1=null;
      String s2=null;
      String str=tf.getText().trim();
      list.add(str);
      tf.setText("");
      try{
       dos.writeUTF(str);
       dos.flush();
      }catch(IOException e1){
         e1.printStackTrace();  
      }
      }
    }
}

然后先運(yùn)行服務(wù)器,再運(yùn)行客戶(hù)端,否則會(huì)報(bào)錯(cuò),因?yàn)镾ocket通信本質(zhì)是先打開(kāi)服務(wù)器監(jiān)聽(tīng)端口。然后就會(huì)出現(xiàn)效果圖。

本機(jī)回環(huán) IP 是 127.0.0.1,你可以改為其他 IP 地址,即可實(shí)現(xiàn)跨機(jī) Socket 通信。

·················· END ··················

相關(guān)推薦

電子產(chǎn)業(yè)圖譜

研究生在讀,熟悉硬件、STM32單片機(jī)、嵌入式Linux。已收獲小米、聯(lián)發(fā)科、浙江大華、上能電氣、英威騰、匯川技術(shù)、格力、富士康等大廠(chǎng)offer。在這里分享求職經(jīng)驗(yàn)、嵌入式學(xué)習(xí)規(guī)劃、考研、嵌入式Linux技術(shù)文章等。