現在有一個需求，就是要去給一臺客戶端主動去傳送指令，或者推送訊息，就尋求朋友問了問告訴我說socket可以實現，所以就在網上找了些資料一遍學習，一遍測試，現在把我最後的成果記錄下來。

        如果對於socket有概念上的不理解的話，可以去百度一下會有很多答案，而且都比較詳細，就不多贅述了。

首先你要先明白你的網路環境（你需要以TCP協議還是UDP協議來互動socket預設是用TCP的，因為我的環境問題使用的UDP），區別服務端和客戶端，我寫了兩個工具類，一個是服務端，一個是客戶端的，主要都是通過輸入輸出流來互動資訊。

程式碼如下：

服務端：

package com.yyg.utils.socket;


import org.apache.log4j.Logger;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintStream;
import java.net.ServerSocket;
import java.net.Socket;

/**
 * 服務端
 */
public class SocketServerUtil {

    private Logger log = Logger.getLogger(SocketServerUtil.class);
    public static final Integer port = 9001;

    public void init () {
        try {
            //建立一個ServerSocket，port是客戶端的埠
            ServerSocket serverSocket = new ServerSocket(port);
            while (true){
                //從請求佇列中取出連結,如果只接受一次則不用使用while迴圈
                Socket socket = serverSocket.accept();
                //獲取客戶端資訊
                BufferedReader input = new BufferedReader(new InputStreamReader(socket.getInputStream()));
                String clientContent = input.readLine();
                //接下來可以對資訊進行操作，我這裡是直接列印了，你可以讀取或者做其他操作
                System.out.println(clientContent);

                //初始化輸出流，回覆客戶端
                PrintStream out = new PrintStream(socket.getOutputStream());
                //獲取鍵盤輸出的內容
                String s = new BufferedReader(new InputStreamReader(System.in)).readLine();
                //將資訊傳送給客戶端
                out.println("open");

                //關閉
                out.close();
                input.close();
            }
        } catch (IOException e) {
            log.error("伺服器異常:" + e);
        }
    }

}
 

客戶端：

 import org.apache.log4j.Logger;


import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintStream;
import java.net.*;

private static Logger log = Logger.getLogger(SocketServerUtil.class);
    public static final Integer port = 9001;
    public static final String host = "127.0.0.1";

    /**
     * 客戶端   傳送TCP協議請求
     * @param str
     */
    public static void connectServerTCP (String str) {
        Socket socket = null;
        try {
            socket = new Socket(host, port);
            //接受服務端傳送的資料
            BufferedReader input = new BufferedReader(new InputStreamReader(socket.getInputStream()));
            //向服務端傳送資料
            PrintStream out = new PrintStream(socket.getOutputStream());
            System.out.println("ready send info to server!!");
            out.println(str);
            System.out.println("send info to server: "+ str);
            //傳送後斷掉連線
            out.close();
            input.close();
        } catch (Exception e) {
            log.error("客戶端連結異常"+ e);
        } finally {
            if (socket != null) {
                try {
                    socket.close();
                } catch (Exception e) {
                    socket = null;
                    log.error("關閉異常"+ e);
                }
            }
        }
    }
 

使用UDP協議的話，因我只寫了客戶端可以參考下，方法如下：

public static void connectUDP (String str) {
        byte[] buf = str.getBytes();
        DatagramPacket packet = new DatagramPacket(buf, buf.length, new InetSocketAddress(host, port));
        try {
            DatagramSocket socket = new DatagramSocket(port);
            socket.send(packet);
            System.out.println(str);
            socket.close();
        } catch (SocketException e) {
            e.printStackTrace();
        }catch (IOException e) {
            e.printStackTrace();
        }

    }