服务器之家:专注于服务器技术及软件下载分享
分类导航

PHP教程|ASP.NET教程|Java教程|ASP教程|编程技术|正则表达式|C/C++|IOS|C#|Swift|Android|JavaScript|易语言|

服务器之家 - 编程语言 - Java教程 - 基于Java语言实现Socket通信的实例

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

2021-07-13 15:18JimmyU1 Java教程

今天小编就为大家分享一篇关于基于Java语言实现Socket通信的实例,小编觉得内容挺不错的,现在分享给大家,具有很好的参考价值,需要的朋友一起跟随小编来看看吧

基于java语言实现socket通信

由于近日项目需求,需要在服务器中增加socket通信的功能,接收硬件设备发送的心跳包和相关数据,因此又重新对java的网络编程进行了复习,根据项目的实际情况做了简化的编程,实现了简单的通信过程。

1. socket通信原理

源ip地址和目的ip地址以及源端口号和目的端口号的组合称为套接字。其用于标识客户端请求的服务器和服务。

以下是通过socket套接字实现客户端与服务器端通信的示意图:

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

在实际应用中,客户端会通过访问服务器的ip和port连接到服务器端,这个过程在服务器和客户端之间创建一个socket,然后通过i/o数据流实现数据传输,也就是socket的通信过程。

2. 服务器端

服务器端模拟接收硬件设备传输的心跳包(一个长度为10的字节数组),服务器端会获取到心跳包以及硬件设备的地址和端口号。

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
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方法
}

3. 客户端

客户端负责每隔一段时间向服务器发送一个心跳包。

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
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方法
}

4. 小结

目前的这种方式比较像目前共享单车的通信模式,通过心跳包来获取client的ip和port,然后server就可以通过心跳包上传的ip和port主动的向client通信了。其他的物联网项目也可以使用这样的方式,这样就可以实现主动的与物联网设备的通信了,只需要规定好协议和传送数据了。 

总结

以上就是这篇文章的全部内容了,希望本文的内容对大家的学习或者工作具有一定的参考学习价值,谢谢大家对服务器之家的支持。如果你想了解更多相关内容请查看下面相关链接

原文链接:https://blog.csdn.net/u012449363/article/details/78522554

延伸 · 阅读

精彩推荐