public class Server extends Thread{
  //服務(wù)器端口號(hào)
  private int port;
  private ServerSocket server = null;
  public Server(){
    //創(chuàng)建一個(gè)服務(wù)器，同時(shí)可以接收10個(gè)設(shè)備發(fā)送的數(shù)據(jù)
    server = new ServerSocket(port,10);
    System.out.println("Socket服務(wù)器啟動(dòng)，開始接受數(shù)據(jù)");
  }
  @Override
  public void run(){
    while (true) {
      Socket socket = null;
      InputStream inputStream = null;
      OutputStream outputStream = null;
      byte[] inputData = new byte[1024];
      try {
        //接收Socket數(shù)據(jù)
        socket = server.accept();
        //獲取遠(yuǎn)程采集機(jī)的IP和端口號(hào)
        String remoteAddress = socket.getInetAddress().toString();
        int remotePort = socket.getPort();
        inputStream = socket.getInputStream();
        //獲取傳入的數(shù)據(jù)長(zhǎng)度
        int length = inputStream.read(inputData);
        //創(chuàng)建輸出流向客戶端返回信息
        outputStream = socket.getOutputStream();
        if (length == 10) {
          //如果長(zhǎng)度等于10，說明傳入的是心跳包
          System.out.println("接收到心跳包，客戶端信息["+remoteAddress+":"+remotePort+"]");
          outputStream.write("success".getBytes());
        } else {
          System.out.println("接收的信息有誤.");
          outputStream.write("failed".getBytes());
        }
      } catch (IOException e) {
        e.printStackTrace();
      } finally {
        try {
          if (inputStream != null) {
            inputStream.close();
          }
          if (outputStream != null) {
            outputStream.close();
          }
          if (socket != null) {
            socket.close();
          }
        } catch (IOException e) {
          e.printStackTrace();
        }
      }
    }
  }
  //省略Getter和Setter方法
}

public final class Client {
  private String address = "";
  private int port = 0;
  private Socket socket = null;
  private Client() {
  }
  private Client(String address, int port) throws IOException {
    this.address = address;
    this.port = port;
    this.socket = new Socket(address, port);
  }
  public static byte[] sendCommand(String address, int port, byte[] data) {
    Client client = null;
    OutputStream outputStream = null;
    InputStream inputStream = null;
    byte[] recevie = new byte[40];
    try {
      client = new Client(address, port);
      outputStream = client.getSocket().getOutputStream();
      outputStream.write(data);
      System.out.print("Send Data Success");
      inputStream = client.getSocket().getInputStream();
      inputStream.read(recevie);
    } catch (IOException e) {
      e.printStackTrace();
    } finally {
      try {
        inputStream.close();
        outputStream.close();
        client.getSocket().close();
      } catch (IOException ioe) {
        System.out.print("IOE when closing resource");
      }
    }
    return recevie;
  }
  /**
   * 測(cè)試函數(shù)
   **/
  public static void test() {
    for (int i = 0; i < 10; i++) {
      //服務(wù)器地址和IP
      String address = "127.0.0.1";
      int port = 9000;
      //心跳包
      byte[] data = "#$*beat001".getBytes();
      String receive = new String(Client.sendCommand(address, port, data));
      System.err.println("第" + i + "次發(fā)送心跳包" + receive);
      try {
        //每隔2分鐘發(fā)送一個(gè)心跳包
        Thread.sleep(2 * 60 * 1000);
      } catch (InterruptedException e) {
        e.printStackTrace();
      }
    }
  }
  //省略Getter和Setter方法
}