[Java] 基于Java语言实现Socket通信的实例

public class server extends thread{
  //服务器端口号
  private int port;
  private serversocket server = null;
  public server(){
  //创建一个服务器，同时可以接收10个设备发送的数据
  server = new serversocket(port,10);
  system.out.println("socket服务器启动，开始接受数据");
  }
  @override
  public void run(){
  while (true) {
    socket socket = null;
    inputstream inputstream = null;
    outputstream outputstream = null;
    byte[] inputdata = new byte[1024];
    try {
    //接收socket数据
    socket = server.accept();
    //获取远程采集机的ip和端口号
    string remoteaddress = socket.getinetaddress().tostring();
    int remoteport = socket.getport();
    inputstream = socket.getinputstream();
    //获取传入的数据长度
    int length = inputstream.read(inputdata);
    //创建输出流向客户端返回信息
    outputstream = socket.getoutputstream();
    if (length == 10) {
      //如果长度等于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;
  }
  /**
   * 测试函数
   **/
  public static void test() {
  for (int i = 0; i < 10; i++) {
    //服务器地址和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 + "次发送心跳包" + receive);
    try {
    //每隔2分钟发送一个心跳包
    thread.sleep(2 * 60 * 1000);
    } catch (interruptedexception e) {
    e.printstacktrace();
    }
  }
  }
  //省略getter和setter方法
}