溫馨提示×
您好，登錄后才能下訂單哦！
點擊 登錄注冊 即表示同意《億速云用戶服務條款》
您好，登錄后才能下訂單哦！
本來想嘗試下如果不使用運營商網絡應用平臺情況下，只是在服務商服務器上是否可以實現對終端完全控制，如果這樣可行，那么物聯網應用服務端更有靈活性。實際情況下，很難實現和運營商網絡對等的處理，用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()
多線程窗口
為了使得服務器端能夠實現同時實現接收和發送，可以在服務器端開啟兩個窗口進行監聽，示例如下：
啟動代碼
#!/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(target=thread_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()
以上就是本文的全部內容，希望對大家的學習有所幫助，也希望大家多多支持億速云。
免責聲明：本站發布的內容（圖片、視頻和文字）以原創、轉載和分享為主，文章觀點不代表本網站立場，如果涉及侵權請聯系站長郵箱：is@yisu.com進行舉報，并提供相關證據，一經查實，將立刻刪除涉嫌侵權內容。
