python实现NB-IoT模块远程控制
本来想尝试下如果不使用运营商网络应用平台情况下，只是在服务商服务器上是否可以实现对终端完全控制，如果这样可行，那么物联网应用服务端更有灵活性。实际情况下，很难实现和运营商网络对等的处理，用python代码原型确实能够实现参数的变化(如PSM,eDXR等)，但是终端分配的IP地址毕竟属于接入网部分，更近似一个局域网，如果采用其他方式访问(如IMSI、IMEI等)，还是需要与运营商核心网进行配合。以下是尝试远程控制的实现方法。
主要实现功能
1、使用pythonpyserial模块通过串口发送AT命令给模组进行参数修改，参考<使用pythonpyserial模块串口通信>;
2、通过inter网进行控制命令传输，选用UDP进行主机控制，参考
3、直接通过NB-IoT无线网络进行控制命令的传输；
4、python多窗口处理服务器端程序，实现接收和发送同时进行；
远程控制主机脚本
服务器端程序：监测UDP对应的端口号，如果接收到register信息则返回allowed，然后进入命令输入状态，等待命令输入完成，发送给终端，等待终端反馈，并接续下一个命令传送。
#!/usr/bin/python3.6
importsocket
importsys
importre
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("serveronline!!waitforregister!")
data,addrRsv=ss.recvfrom(BUFFER_SIZE)
ifnotdata:
sys.exit(0)
else:
print(data)
if(re.match(b'register',data)):
ss.sendto(b'allowed',addrRsv)
else:
ss.sendto(b'reject',addrRsv)
whileTrue:
#等待命令输入
aa=input('cmd>')
ifnotaa:
break
else:
cmdV=aa+'\r'
ss.sendto(cmdV.encode('utf-8'),addrRsv)
#等待结果返回
data,addrRsv=ss.recvfrom(BUFFER_SIZE)
ifnotdata:
break
else:
print(data)
ss.close()
客户主机程序：发送register并成功接收allowed后，等待控制命令，通过串口转发给终端模块，并接收终端模块的反馈消息，返回给服务器侧。
#!/usr/bin/python3.6
importserial
importsys
importos
importre
importsocket
#初始化UART端口
ser=serial.Serial("COM5",9600,timeout=30)
#选择相应的协议类型UDP
ss=socket.socket(socket.AF_INET,socket.SOCK_DGRAM)
BUFFER_SIZE=1024
TARGET_ADDR='IPaddress'
TARGET_PORT=60000
TARGET=(TARGET_ADDR,TARGET_PORT)
aa='开机命令'.encode('utf-8')#converttobytestype
ser.write(aa)
whileTrue:
line=ser.readline()
ifnotline:
print("cannotgetcmdresult,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)
ifre.match(b'allowed',data):
print('registersuccessfully!')
pass
else:
print('registerfailure')
sys.exit(0)
whileTrue:
data,addrRsv=ss.recvfrom(BUFFER_SIZE)
ifnotdata:
print("timeout,releasenow!!")
break
elifre.match(b'end',data):
print("endofprocess!!")
break;
ser.write(data)
whileTrue:
line=ser.readline()
ifnotline:
print("cannotgetcmdresult,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()
多线程窗口
为了使得服务器端能够实现同时实现接收和发送，可以在服务器端开启两个窗口进行监听，示例如下：
启动代码
#!/usr/bin/python3.6
importthreading
importtime
importsubprocess
importos
importsys
defthread_fun1():
#globalvlock
while(1):
print("threadfun1isrunning!!!")
time.sleep(1)
#......
print(len(sys.argv))
#vlock=threading.Lock()
t1=threading.Thread(target=thread_fun1,args=())
t1.start()
addr='IPaddress'
port=60000
cmdStr="pythonanotherThread.py%s%d"%(addr,port)
#设置creationflags=subprocess.CREATE_NEW_CONSOLE，用来创建新的控制台窗口
subprocess.Popen(cmdStr,creationflags=subprocess.CREATE_NEW_CONSOLE)
anotherThread.py
#!/usr/bin/python3.6
defthread_fun2():
while(1):
aa=input('cmd>')
print("threadfun2isrunning!!!")
print(aa)
if(aa=='end'):
break
thread_fun2()
以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持毛票票。