动态链接做网站外链图,网站开发公司凭证,在大学做网站,宁夏网站建设哪个好本来想尝试下如果不使用运营商网络应用平台情况下#xff0c;只是在服务商服务器上是否可以实现对终端完全控制#xff0c;如果这样可行#xff0c;那么物联网应用服务端更有灵活性。实际情况下#xff0c;很难实现和运营商网络对等的处理#xff0c;用python代码原型确实…本来想尝试下如果不使用运营商网络应用平台情况下只是在服务商服务器上是否可以实现对终端完全控制如果这样可行那么物联网应用服务端更有灵活性。实际情况下很难实现和运营商网络对等的处理用python代码原型确实能够实现参数的变化(如PSM,eDXR等)但是终端分配的IP地址毕竟属于接入网部分更近似一个局域网如果采用其他方式访问(如IMSI、IMEI等)还是需要与运营商核心网进行配合。以下是尝试远程控制的实现方法。
主要实现功能
1、使用python pyserial模块通过串口发送AT命令给模组进行参数修改参考使用python pyserial模块串口通信;
2、通过inter网进行控制命令传输选用UDP进行主机控制参考
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(bregister,data)):
ss.sendto(ballowed,addrRsv)
else:
ss.sendto(breject,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,timeout30)
#选择相应的协议类型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(bOK,line) ):
break
ss.sendto(bytes(register,utf-8),TARGET)
data,addrRsv ss.recvfrom(BUFFER_SIZE)
if re.match(ballowed,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(bend,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(bOK,line) ):
ss.sendto(bytes(OK,utf-8),TARGET)
break
elif(re.match(bERROR,line)):
ss.sendto(bytes(ERROR,utf-8),TARGET)
break
else:
pass
ser.close()
多线程窗口
为了使得服务器端能够实现同时实现接收和发送可以在服务器端开启两个窗口进行监听示例如下
启动代码
#!/usr/bin/python3.6
import threading
import time
import subprocess
import os
import sys
def thread_fun1():
#global vlock
while(1):
print(thread fun1 is running!!!)
time.sleep(1)
#... ...
print(len(sys.argv))
#vlock threading.Lock()
t1 threading.Thread(targetthread_fun1,args())
t1.start()
addr IP address
port 60000
cmdStr python anotherThread.py %s %d%(addr,port)
#设置creationflags subprocess.CREATE_NEW_CONSOLE用来创建新的控制台窗口
subprocess.Popen(cmdStr,creationflags subprocess.CREATE_NEW_CONSOLE)
anotherThread.py
#!/usr/bin/python3.6
def thread_fun2():
while(1):
aa input(cmd )
print(thread fun2 is running!!!)
print(aa)
if(aa end):
break
thread_fun2()
以上就是本文的全部内容希望对大家的学习有所帮助也希望大家多多支持脚本之家。
