網(wǎng)絡(luò)上的兩個(gè)程序通過(guò)一個(gè)雙向的通信連接實(shí)現(xiàn)數(shù)據(jù)的交換，這個(gè)連接的一端稱為一個(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)名稱)

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

兩個(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("從客戶端接受的數(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ù)器端");              //窗體名稱  
  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("客戶端"); 
  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)行客戶端，否則會(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 通信。

本文轉(zhuǎn)載自微信公眾號(hào)「嵌入式Linux系統(tǒng)開(kāi)發(fā)」，可以通過(guò)以下二維碼關(guān)注。轉(zhuǎn)載本文請(qǐng)聯(lián)系嵌入式Linux系統(tǒng)開(kāi)發(fā)眾號(hào)。