docker run -d --name elasticsearchv7 -p 9200:9200 -p 9300:9300 -e "discovery.type=single-node" -e "ES_JAVA_OPTS=-Xms6024m -Xmx6024m" elasticsearch:7.17.7

* soft nofile 655350
* hard nofile 655350

# 设置最大句柄
ulimit -n 655350
# 增加虚拟网卡
sudo ifconfig enp0s3:1 192.168.31.51 up
sudo ifconfig enp0s3:2 192.168.31.52 up

# 运行
java -jar device-simulator.jar mqtt.address=192.168.31.197 mqtt.port=9010 mqtt.limit=10000 mqtt.eventLimit=10000 mqtt.start=1111 mqtt.batchSize=1000 mqtt.binds=192.168.31.50,192.168.31.51,192.168.31.52

{
  "events": [],
  "properties": [
    {
      "id": "temperature",
      "name": "温度",
      "expands": {
        "readOnly": null
      },
      "description": null,
      "scale": 2,
      "unit": null,
      "type": "float"
    },
    {
      "id": "light",
      "name": "亮度",
      "expands": {
        "readOnly": null
      },
      "description": null,
      "unit": null,
      "type": "int"
    },
    {
      "id": "humidity",
      "name": "湿度",
      "expands": {
        "readOnly": null
      },
      "description": null,
      "unit": null,
      "type": "long"
    },
    {
      "id": "current",
      "name": "电流",
      "expands": {
        "readOnly": null
      },
      "description": null,
      "unit": null,
      "type": "int"
    },
    {
      "id": "voltage",
      "name": "电压",
      "expands": {
        "readOnly": null
      },
      "description": null,
      "scale": 2,
      "unit": null,
      "type": "double"
    }
  ],
  "functions": []
}

function OnConnect(context) {
  context.DeviceOnline(context.GetClientId())
}

function OnMessage(context) {
  console.log("OnMessage: " + context.MsgToString())
  var data = JSON.parse(context.MsgToString())
    if (data.name == 'reply') {
        context.ReplyOk()
        return
    }
  var topic = context.Topic()
  if (topic == '/report-property') {
    context.SaveProperties(data)
  } else if (topic == '/event') {
    context.SaveEvents(data.eventId, data)
  }
}
function OnInvoke(context) {
  var data = JSON.stringify(context.GetMessage().Data)
    console.log("OnInvoke: " + data)
  var session = context.GetSession()
  // 向Broker发送文本信息
    session.Publish("/invoke", data)
}

create mqtt client: 9000 ok
create mqtt client: 10000 ok

max : 1571ms
min : 525ms
avg : 956ms

> 5000ms : 0(0.00%)
> 2000ms : 0(0.00%)
> 1000ms : 2935(29.35%)
> 500ms : 7065(70.65%)
> 200ms : 0(0.00%)
> 100ms : 0(0.00%)
> 10ms : 0(0.00%)

# CPU、内存使用情况
top - 15:29:57 up 10:34,  2 users,  load average: 4.69, 1.75, 0.83
Tasks: 140 total,   1 running, 139 sleeping,   0 stopped,   0 zombie
%Cpu(s): 67.4 us,  3.1 sy,  0.0 ni, 19.5 id,  0.4 wa,  0.0 hi,  9.7 si,  0.0 st
KiB Mem : 83.2/6831120  [|||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||         ]
KiB Swap:  0.6/3145724 [|                                                            ]

  PID USER      PR  NI    VIRT    RES    SHR S  %CPU %MEM     TIME+ COMMAND                                                                      
13100 root      20   0 1023088 299000  12652 S 245.8  4.4   3:38.39 go-iot                                                                       
 3297 1000      20   0 7474404   3.8g  38236 S  41.2 58.3  14:30.41 java

# go-iot运行状态
Count	Profile
422	allocs
0	block
0	cmdline
20020	goroutine
422	heap
0	mutex
0	profile
8	threadcreate
0	trace

create mqtt client: 98000 ok
create mqtt client: 99000 ok
create mqtt client: 100000 ok

max : 3644ms
min : 488ms
avg : 727ms

> 5000ms : 0(0.00%)
> 2000ms : 2010(2.01%)
> 1000ms : 6335(6.33%)
> 500ms : 90038(90.04%)
> 200ms : 1617(1.62%)
> 100ms : 0(0.00%)
> 10ms : 0(0.00%)

# CPU、内存使用情况
%Cpu(s):  4.8 us, 10.9 sy,  0.0 ni, 63.2 id,  0.0 wa,  0.0 hi, 21.1 si,  0.0 st
KiB Mem : 79.3/12184576 [||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||                    ]
KiB Swap:  0.0/3145724  [                                                                                                    ]

  PID USER      PR  NI    VIRT    RES    SHR S  %CPU %MEM     TIME+ COMMAND                                                                                                                                                                
 3072 root      20   0 2213244   1.2g   9928 S  96.0 10.4   3:41.42 go-iot

# go-iot运行状态
Count	Profile
210	allocs
0	block
0	cmdline
200019	goroutine
210	heap
0	mutex
0	profile
9	threadcreate
0	trace