網(wǎng)絡(luò)通信-Socket

參考：https://blog.csdn.net/hzw2017/article/details/81210979

Socket浙炼，即套接字订框，是一個對 TCP/IP 協(xié)議進(jìn)行封裝的編程調(diào)用接口（API）浑吟。

位于傳輸層，是網(wǎng)絡(luò)上的兩個程序通過一個雙向的通信連接實現(xiàn)數(shù)據(jù)交換的一種進(jìn)程通信方式之一。
成對出現(xiàn)霎终，一對套接字灸促。

Android與服務(wù)器的通信方式主要有兩種诫欠，一是Http通信，一是Socket通信浴栽。兩者的最大差異在于荒叼，Http連接使用的是“請求—響應(yīng)方式”，即在請求時建立連接通道典鸡，當(dāng)客戶端向服務(wù)器發(fā)送請求后被廓，服務(wù)器端才能向客戶端返回數(shù)據(jù)。而Socket通信則是在雙方建立起連接后就可以直接進(jìn)行數(shù)據(jù)的傳輸萝玷，在連接時可實現(xiàn)信息的主動推送嫁乘，而不需要每次由客戶端向服務(wù)器發(fā)送請求昆婿。

簡單來說，Socket提供了程序內(nèi)部與外界通信的端口并為通信雙方的提供了數(shù)據(jù)傳輸通道蜓斧。

Socket在JAVA中的簡單實現(xiàn)

以TCP為例身腻。

使用步驟

客戶端

創(chuàng)建Socket對象，指定成對的服務(wù)端IP地址和端口號闽寡。
通過Socket獲取輸出流帮碰，寫入數(shù)據(jù)發(fā)給服務(wù)端相味。
通過Socket獲取輸入流，接受服務(wù)端的發(fā)送的數(shù)據(jù)殉挽。
關(guān)閉資源close丰涉。

服務(wù)端

創(chuàng)建ServerSocket對象，并指定端口號斯碌，其端口號必須與客戶端一致一死。
通過ServerSocket對象，獲取客戶端的Socket實例（ServerSocket.accept()方法）傻唾。
通過Socket獲取輸入流投慈，接受客戶端發(fā)來的消息。
通過Socket獲取輸出流冠骄，寫入數(shù)據(jù)向客戶端發(fā)送數(shù)據(jù)作為回應(yīng)伪煤。
關(guān)閉資源close。

Socket在Android中

基于TCP協(xié)議

服務(wù)器端首先聲明一個ServerSocket對象并指定監(jiān)聽的端口號凛辣。調(diào)用ServerSocket的accept()方法接收客戶端的數(shù)據(jù)抱既。accept()方法在沒有數(shù)據(jù)進(jìn)行接收時處于阻塞狀態(tài)。

// 創(chuàng)建一個ServerSocket對象扁誓，指定端口為7777
ServerSocket serverSocket = new ServerSocket(7777);  

// 調(diào)用ServerSocket的accept()方法防泵，接受客戶端所發(fā)送的請求
// 如果客戶端沒有發(fā)送數(shù)據(jù)，那么該線程就停滯不繼續(xù)
Socket socket = serverSocket.accept();

一旦接收到數(shù)據(jù)蝗敢，通過InputStream讀取接收的數(shù)據(jù)捷泞。

// 從Socket當(dāng)中得到InputStream對象
InputStream inputStream = socket.getInputStream(); 

byte buffer[] = new byte[1024 * 4];  
int temp = 0;  
// 從InputStream當(dāng)中讀取客戶端所發(fā)送的數(shù)據(jù)  
while ((temp = inputStream.read(buffer)) != -1) {  
  System.out.println(new String(buffer, 0, temp));  
}

客戶端創(chuàng)建一個Socket對象，指定服務(wù)端的IP和端口號寿谴，通過InputSream讀取數(shù)據(jù)锁右，獲取服務(wù)器發(fā)出的數(shù)據(jù)。

// 創(chuàng)建一個Socket對象，并指定服務(wù)端的IP及端口號
Socket socket = new Socket(ip, 7777);

// 創(chuàng)建一個InputStream用戶讀取要發(fā)送的文件
InputStream inputStream = new FileInputStream("xxx");

最后將要發(fā)送的數(shù)據(jù)寫入到OutputStream骡湖，即可進(jìn)行TCP協(xié)議的Socket數(shù)據(jù)傳輸贱纠。

// 獲取Socket的OutputStream對象用于發(fā)送數(shù)據(jù)。  
OutputStream outputStream = socket.getOutputStream();  

// 創(chuàng)建一個byte類型的buffer字節(jié)數(shù)組响蕴，用于存放讀取的本地文件  
byte buffer[] = new byte[4 * 1024];  
int temp = 0;  
// 循環(huán)讀取文件  
while ((temp = inputStream.read(buffer)) != -1) {  
  // 把數(shù)據(jù)寫入到OuputStream對象中  
  outputStream.write(buffer, 0, temp);  
}  
// 發(fā)送讀取的數(shù)據(jù)到服務(wù)端  
outputStream.flush();

基于UDP協(xié)議

服務(wù)器端首先創(chuàng)建一個DatagramSocket對象谆焊，并指定監(jiān)聽的端口號。創(chuàng)建一個空的DatagramSocket對象用于接收數(shù)據(jù)（byte[] data=new byte[1024]; DatagramSocket socket=new DatagramSocket(data, data.length)）浦夷，使用DatagramSocket的receive()方法接收客戶端發(fā)送的數(shù)據(jù)辖试。receive()與ServerSocket.accept()類似，在沒有數(shù)據(jù)進(jìn)行接收時處于阻塞狀態(tài)劈狐。

    DatagramSocket socket;
    try {
        // 創(chuàng)建DatagramSocket對象并指定一個端口號罐孝，
        // 注意：如果客戶端需要接收服務(wù)器的返回數(shù)據(jù),  還需要使用這個端口號來receive
        socket = new DatagramSocket(1985);
        // 使用InetAddress(Inet4Address).getByName把IP地址轉(zhuǎn)換為網(wǎng)絡(luò)地址
        InetAddress serverAddress = InetAddress.getByName("192.168.1.32");  
        // Inet4Address serverAddress = (Inet4Address) Inet4Address.getByName("192.168.1.32");
        // 設(shè)置要發(fā)送的報文
        String str = "[2143213;21343fjks;213]";
        // 把字符串str字符串轉(zhuǎn)換為字節(jié)數(shù)組
        byte data[] = str.getBytes();
        // 創(chuàng)建一個DatagramPacket對象，用于發(fā)送數(shù)據(jù)肥缔。
        // 參數(shù)一：要發(fā)送的數(shù)據(jù)莲兢，參數(shù)二：數(shù)據(jù)的長度，參數(shù)三：服務(wù)端的網(wǎng)絡(luò)地址续膳，參數(shù)四：服務(wù)器端端口號
        DatagramPacket packet = new DatagramPacket(data, data.length, serverAddress, 10025);
        // 把數(shù)據(jù)發(fā)送到服務(wù)端改艇。
        socket.send(packet);    
    } catch (SocketException e) {  
        e.printStackTrace();  
    } catch (UnknownHostException e) {  
        e.printStackTrace();  
    } catch (IOException e) {  
        e.printStackTrace();  
    }

客戶端也創(chuàng)建一個DatagramSocket對象，并指定端口坟岔。創(chuàng)建一個InetAddress對象谒兄，該對象類似于一個網(wǎng)絡(luò)的發(fā)送地址（InetAddress ia=InetAddress.getByName(ip)），定義要發(fā)送的字符串社付，創(chuàng)建一個DatagramPacket對象承疲，并指定要將該數(shù)據(jù)包發(fā)送到網(wǎng)絡(luò)的哪個IP及端口號，最后使用DatagramSocket的send()方法發(fā)送數(shù)據(jù)鸥咖。（String str="hello"; byte[] data=str.getByte(); DatagramPacket packet=new DatagramPacket(data, data.length, serveraddress, port); socket.send(packet);）

    DatagramSocket socket;  
    try {  
        // 實例化的端口號要和發(fā)送時的socket一致燕鸽，否則收不到data  
        socket = new DatagramSocket(1985);  
        byte data[] = new byte[4 * 1024];  
        // 參數(shù)一:要接受的data，參數(shù)二：data的長度  
        DatagramPacket packet = new DatagramPacket(data, data.length);  
        socket.receive(packet);  
        // 把接收到的data轉(zhuǎn)換為String字符串  
        String result = new String(packet.getData(), packet.getOffset(), packet.getLength());
        // 不使用了記得要關(guān)閉
        socket.close();  
        System.out.println("the number of reveived Socket is  :" + flag  
                + "udpData:" + result);  
    } catch (SocketException e) {  
        e.printStackTrace();  
    } catch (IOException e) {  
        e.printStackTrace();  
    }