作者 陈俊学

2.1.2

修改重连mqtt累加
@@ -4,5 +4,5 @@ SERVER: @@ -4,5 +4,5 @@ SERVER:
4 reconnect_interval: 3 4 reconnect_interval: 3
5 5
6 VERSION: 6 VERSION:
7 - code: 101  
8 - name: 2.1.1  
  7 + code: 102
  8 + name: 2.1.2
@@ -262,7 +262,7 @@ class MqttClient(mqtt.Client): @@ -262,7 +262,7 @@ class MqttClient(mqtt.Client):
262 return self.status 262 return self.status
263 263
264 def _send_pingreq(self): 264 def _send_pingreq(self):
265 - self._ping_counter = self._ping_counter + 1 265 + self._ping_counter += 1
266 if self._ping_counter * 10 == 3600 * 4: 266 if self._ping_counter * 10 == 3600 * 4:
267 print(threading.current_thread().name, '每隔4小时自动重连') 267 print(threading.current_thread().name, '每隔4小时自动重连')
268 self._ping_counter = 0 268 self._ping_counter = 0
@@ -29,7 +29,7 @@ def post_terminal_info(name_f, source_ws_f, num_f, version_f, set_latest_f): @@ -29,7 +29,7 @@ def post_terminal_info(name_f, source_ws_f, num_f, version_f, set_latest_f):
29 _host = netutil.getip() 29 _host = netutil.getip()
30 data['ip'] = _host 30 data['ip'] = _host
31 try: 31 try:
32 - r = requests.post(SERVER + '/post_terminal_info', json=data, timeout=2) 32 + r = requests.post(SERVER + '/post_terminal_info', json=data, timeout=15)
33 res= r.json().get('data', {}) 33 res= r.json().get('data', {})
34 new_ws =res.get('ws', data['ws']) 34 new_ws =res.get('ws', data['ws'])
35 set_latest_f(res['ver']) 35 set_latest_f(res['ver'])