本來想嘗試下如果不使用運營商網絡應用平臺情況下,只是在服務商服務器上是否可以實現對終端完全控制,如果這樣可行,那么物聯網應用服務端更有靈活性。實際情況下,很難實現和運營商網絡對等的處理,用python代碼原型確實能夠實現參數的變化(如PSM,eDXR等),但是終端分配的IP地址畢竟屬于接入網部分,更近似一個局域網,如果采用其他方式訪問(如IMSI、IMEI等),還是需要與運營商核心網進行配合。以下是嘗試遠程控制的實現方法。
主要實現功能
1、使用python pyserial模塊通過串口發送AT命令給模組進行參數修改,參考<使用python pyserial模塊串口通信>;
2、通過inter網進行控制命令傳輸,選用UDP進行主機控制,參考<python socket網絡接口編程>;
3、直接通過NB-IoT無線網絡進行控制命令的傳輸;
4、python多窗口處理服務器端程序,實現接收和發送同時進行;
遠程控制主機腳本
服務器端程序:監測UDP對應的端口號,如果接收到register信息則返回allowed,然后進入命令輸入狀態,等待命令輸入完成,發送給終端,等待終端反饋,并接續下一個命令傳送。
#!/usr/bin/python3.6 import socket import sys import re BUFFER_SIZE = 1024 TARGET_ADDR = '' TARGET_PORT = 60000 TARGET = (TARGET_ADDR,TARGET_PORT) ss = socket.socket(socket.AF_INET,socket.SOCK_DGRAM) ss.bind(TARGET) print("server online!! wait for register!") data,addrRsv = ss.recvfrom(BUFFER_SIZE) if not data: sys.exit(0) else: print(data) if(re.match(b'register',data)): ss.sendto(b'allowed',addrRsv) else: ss.sendto(b'reject',addrRsv) while True: #等待命令輸入 aa = input('cmd > ') if not aa: break else: cmdV = aa+'/r' ss.sendto(cmdV.encode('utf-8'),addrRsv) #等待結果返回 data,addrRsv = ss.recvfrom(BUFFER_SIZE) if not data: break else: print(data) ss.close()
客戶主機程序:發送register并成功接收allowed后,等待控制命令,通過串口轉發給終端模塊,并接收終端模塊的反饋消息,返回給服務器側。
#!/usr/bin/python3.6 import serial import sys import os import re import socket #初始化UART端口 ser = serial.Serial("COM5",9600,timeout=30) #選擇相應的協議類型UDP ss = socket.socket(socket.AF_INET,socket.SOCK_DGRAM) BUFFER_SIZE = 1024 TARGET_ADDR = 'IP address' TARGET_PORT = 60000 TARGET = (TARGET_ADDR,TARGET_PORT) aa = '開機命令'.encode('utf-8') #convert to bytes type ser.write(aa) while True: line = ser.readline() if not line: print("can not get cmd result, release!") sys.exit(0) print(line) if ( re.match(b'OK',line) ): break ss.sendto(bytes('register','utf-8'),TARGET) data,addrRsv = ss.recvfrom(BUFFER_SIZE) if re.match(b'allowed',data): print('register successfully!') pass else: print('register failure') sys.exit(0) while True: data,addrRsv = ss.recvfrom(BUFFER_SIZE) if not data: print("time out,release now!!") break elif re.match(b'end',data): print("end of process!!") break; ser.write(data) while True: line = ser.readline() if not line: print("can not get cmd result, release!") break print(line) if ( re.match(b'OK',line) ): ss.sendto(bytes('OK','utf-8'),TARGET) break elif(re.match(b'ERROR',line)): ss.sendto(bytes('ERROR','utf-8'),TARGET) break else: pass ser.close()
新聞熱點
疑難解答