![[ 电子]STM32驱动28BYJ-48步进电机实现外网控制](https://600zi.400zi.cn/uploadfile/img/15/385/c7f7183e5bc60236dae8ebd3aa8c3dd5.jpg)
新人博主Github==>/MartinxMax
这个项目能做什么?用到了哪些编程语言？需要什么硬件?硬件接线配置SIM900ASTM32 C语言代码服务器 Python流量转发代码控制端 Python代码效果演示这个项目能做什么?
解除局域网内限制，实现任意地方远程控制开关电闸，远程控制空调开关等…
用到了哪些编程语言？
C语言,Python3.6以上版本，附源代码
需要什么硬件?
最低总合计约83￥
1.STM32F03CT6开发板(价格23￥左右)
2.I2C驱动的4针脚OLED显示屏(价格14￥左右)
SIM900A模块(价格28￥左右)
可以流量上网的SIM手机卡(移动或联通)
28BYJ-48步进电机(5V)+ULN驱动板(9￥左右)
一台装有Python环境的服务器
发光二极管(用于网络检测)
CP2102(用于调试SIM900A，9￥左右)
天线(SIM900A模块天线靠太近容易干扰影响通讯)
硬件接线
配置SIM900A
接线图
插入手机卡配置AT命令1、AT\r\n 2、AT+CGCLASS="B"\r\n[ AT+CGCLASS="B"，设置移动台类别为 B]3、AT+CGDCONT=1,"IP","CMNET"\r\n[设置 PDP 上下文标志为 1，接入点为"CMNET"]4、AT+CGATT=1\r\n[GPRS业务]5、AT+CIPCSGP=1,"CMNET"\r\n
STM32 C语言代码
下载源代码
# 将这一行改写成你的服务器IPSerial_SendString("AT+CIPSTART=\"TCP\",\"xx.xx.xx.xx\",\"10030\"\r\n");
服务器 Python流量转发代码
#!/usr/bin/python3import socketimport sysimport timeimport datetimeimport threadingDEV_SOCK_AND_USERNAME_PORT = list()HCK_SOCK_AND_USERNAME_PORT = list()mutex = threading.Lock()def SOCK_Dev(PORT):global DEV_SOCK_AND_USERNAME_PORT,HCK_SOCK_AND_USERNAME_PORTMIAN_DEV_SOCK = socket.socket(socket.AF_INET, socket.SOCK_STREAM)MIAN_DEV_SOCK.bind(("", PORT))MIAN_DEV_SOCK.listen(1)while True:print(f"[*]等待远程设备连接...\033[4;33m{PORT}\033[0m")DEV_SOCKET, DevIP = MIAN_DEV_SOCK.accept()print(f"[\033[34m+\033[0m]设备 \033[32m{DevIP[0]}\033[0m:\033[4;33m{DevIP[1]}"f"\033[0m ---------- [\033[32mOnline\033[0m]-[\033[4;33m{PORT}\033[0m]")DEV_SOCK_AND_USERNAME_PORT.append(DEV_SOCKET)DEV_SOCK_AND_USERNAME_PORT.append(DevIP[0])DEV_SOCK_AND_USERNAME_PORT.append(DevIP[1])while True:try:DEV_SOCKET.send(b'x')except:breakelse:time.sleep(5)DEV_SOCK_AND_USERNAME_PORT.remove(DEV_SOCKET)DEV_SOCK_AND_USERNAME_PORT.remove(DevIP[0])DEV_SOCK_AND_USERNAME_PORT.remove(DevIP[1])def Get_DATA(SOCK,Name,Mote):DATA = SOCK.recv(1024).decode()if len(DATA) <= 0: # 断开连接了if Mote == 0:print(f"[\033[34m-\033[0m]\033[32m{Name}\033[0m ---------- [\033[32mOffline\033[0m]")else:print(f"[\033[34m-\033[0m]\033[31m{Name}\033[0m ---------- [\033[32mOffline\033[0m]")return 0return DATAdef SOCK_Hacker(PORT):global DEV_SOCK_AND_USERNAME_PORT,HCK_SOCK_AND_USERNAME_PORTMIAN_HACK_SOCK = socket.socket(socket.AF_INET, socket.SOCK_STREAM)MIAN_HACK_SOCK.bind(("", PORT))MIAN_HACK_SOCK.listen(1)while True:print(f"[*]等待控制者连接...\033[4;33m{PORT}\033[0m")HACK_SOCKET, Hacker_IP = MIAN_HACK_SOCK.accept()print(f"[\033[34m+\033[0m]控制者 \033[31m{Hacker_IP[0]}\033[0m:\033[4;33m{Hacker_IP[1]}"f"\033[0m ---------- [\033[32mOnline\033[0m]-[\033[4;33m{PORT}\033[0m]")HACK_SOCKET.send(b"[+]Server Connect You !")HCK_SOCK_AND_USERNAME_PORT.append(HACK_SOCKET)HCK_SOCK_AND_USERNAME_PORT.append(Hacker_IP[0])HCK_SOCK_AND_USERNAME_PORT.append(Hacker_IP[1])#HCK_SOCK = HACK_SOCKETwhile True:DATA = Get_DATA(HACK_SOCKET, Hacker_IP[0],1)mutex.acquire()if DATA != 0:if 'EXIT' in DATA:HACK_SOCKET.send("Socket Cloese-----[Success]".encode())HCK_SOCK_AND_USERNAME_PORT[0].close()print(f"[\033[34m-\033[0m]Hacker SOCKET 已被关闭")breakelif 'DEV' in DATA:DEV_SOCK_AND_USERNAME_PORT[0].send(b'y')HACK_SOCKET.send("Device Cloese Socket-----[Success]".encode())if DEV_SOCK_AND_USERNAME_PORT:HACK_SOCKET.send(f"Device----[Online]\r\n".encode())now = datetime.datetime.now()print(f"\033[31m{Hacker_IP[0]}\033[0m ==> \033[32m{DEV_SOCK_AND_USERNAME_PORT[1]}\033[0m ---------- [\033[32mOK\033[0m] %s" % (now.strftime("%Y-%m-%d %H:%M:%S")))if 'HACK' in DATA:DEV_SOCK_AND_USERNAME_PORT[0].send(b'o')HACK_SOCKET.send(f"Server Send {DEV_SOCK_AND_USERNAME_PORT[1]} RUN Command !!Success!!".encode())print(f"启动----------[\033[32mOK\033[0m]")elif 'STOP' in DATA:DEV_SOCK_AND_USERNAME_PORT[0].send(b'c')HACK_SOCKET.send(f"Server Send {DEV_SOCK_AND_USERNAME_PORT[1]} STOP Command !!Success!!".encode())print(f"停止----------[\033[32mOK\033[0m]")else:HACK_SOCKET.send(f"Device----[OffLine]".encode())mutex.release()else:HACK_SOCKET.close()mutex.release()breakHCK_SOCK_AND_USERNAME_PORT.remove(HACK_SOCKET)HCK_SOCK_AND_USERNAME_PORT.remove(Hacker_IP[0])HCK_SOCK_AND_USERNAME_PORT.remove(Hacker_IP[1])def main():Hacker = threading.Thread(target=SOCK_Hacker,args=(10031,))Device = threading.Thread(target=SOCK_Dev,args=(10030,))Hacker.start()Device.start()if __name__ == '__main__':main()
运行效果图
这里有些小伙伴可能会出现乱码和报错，把全部中文改成英文即可，若系统并非Linux则将带有print中输出颜色代码(\033[3x和\033)去除即可
无法识别中文修改版
#!/usr/bin/python3import socketimport sysimport timeimport datetimeimport threadingDEV_SOCK_AND_USERNAME_PORT = list()HCK_SOCK_AND_USERNAME_PORT = list()mutex = threading.Lock()def SOCK_Dev(PORT):global DEV_SOCK_AND_USERNAME_PORT,HCK_SOCK_AND_USERNAME_PORTMIAN_DEV_SOCK = socket.socket(socket.AF_INET, socket.SOCK_STREAM)MIAN_DEV_SOCK.bind(("", PORT))MIAN_DEV_SOCK.listen(1)while True:print(f"[*]Waiting for remote device connection...\033[4;33m{PORT}\033[0m")DEV_SOCKET, DevIP = MIAN_DEV_SOCK.accept()print(f"[\033[34m+\033[0m]Device \033[32m{DevIP[0]}\033[0m:\033[4;33m{DevIP[1]}"f"\033[0m ---------- [\033[32mOnline\033[0m]-[\033[4;33m{PORT}\033[0m]")DEV_SOCK_AND_USERNAME_PORT.append(DEV_SOCKET)DEV_SOCK_AND_USERNAME_PORT.append(DevIP[0])DEV_SOCK_AND_USERNAME_PORT.append(DevIP[1])while True:try:DEV_SOCKET.send(b'x')except:breakelse:time.sleep(5)DEV_SOCK_AND_USERNAME_PORT.remove(DEV_SOCKET)DEV_SOCK_AND_USERNAME_PORT.remove(DevIP[0])DEV_SOCK_AND_USERNAME_PORT.remove(DevIP[1])def Get_DATA(SOCK,Name,Mote):DATA = SOCK.recv(1024).decode()if len(DATA) <= 0:if Mote == 0:print(f"[\033[34m-\033[0m]\033[32m{Name}\033[0m ---------- [\033[32mOffline\033[0m]")else:print(f"[\033[34m-\033[0m]\033[31m{Name}\033[0m ---------- [\033[32mOffline\033[0m]")return 0return DATAdef SOCK_Hacker(PORT):global DEV_SOCK_AND_USERNAME_PORT,HCK_SOCK_AND_USERNAME_PORTMIAN_HACK_SOCK = socket.socket(socket.AF_INET, socket.SOCK_STREAM)MIAN_HACK_SOCK.bind(("", PORT))MIAN_HACK_SOCK.listen(1)while True:print(f"[*]Waiting for the controller to connect...\033[4;33m{PORT}\033[0m")HACK_SOCKET, Hacker_IP = MIAN_HACK_SOCK.accept()print(f"[\033[34m+\033[0m]Controller \033[31m{Hacker_IP[0]}\033[0m:\033[4;33m{Hacker_IP[1]}"f"\033[0m ---------- [\033[32mOnline\033[0m]-[\033[4;33m{PORT}\033[0m]")HACK_SOCKET.send(b"[+]Server Connect You !")HCK_SOCK_AND_USERNAME_PORT.append(HACK_SOCKET)HCK_SOCK_AND_USERNAME_PORT.append(Hacker_IP[0])HCK_SOCK_AND_USERNAME_PORT.append(Hacker_IP[1])#HCK_SOCK = HACK_SOCKETwhile True:DATA = Get_DATA(HACK_SOCKET, Hacker_IP[0],1)mutex.acquire()if DATA != 0:if 'EXIT' in DATA:HACK_SOCKET.send("Socket Cloese-----[Success]".encode())HCK_SOCK_AND_USERNAME_PORT[0].close()print(f"[\033[34m-\033[0m]Hacker SOCKET 已被关闭")breakelif 'DEV' in DATA:DEV_SOCK_AND_USERNAME_PORT[0].send(b'y')HACK_SOCKET.send("Device Cloese Socket-----[Success]".encode())if DEV_SOCK_AND_USERNAME_PORT:HACK_SOCKET.send(f"Device----[Online]\r\n".encode())now = datetime.datetime.now()print(f"\033[31m{Hacker_IP[0]}\033[0m ==> \033[32m{DEV_SOCK_AND_USERNAME_PORT[1]}\033[0m ---------- [\033[32mOK\033[0m] %s" % (now.strftime("%Y-%m-%d %H:%M:%S")))if 'HACK' in DATA:DEV_SOCK_AND_USERNAME_PORT[0].send(b'o')HACK_SOCKET.send(f"Server Send {DEV_SOCK_AND_USERNAME_PORT[1]} RUN Command !!Success!!".encode())print(f"Runing----------[\033[32mOK\033[0m]")elif 'STOP' in DATA:DEV_SOCK_AND_USERNAME_PORT[0].send(b'c')HACK_SOCKET.send(f"Server Send {DEV_SOCK_AND_USERNAME_PORT[1]} STOP Command !!Success!!".encode())print(f"Stoping----------[\033[32mOK\033[0m]")else:HACK_SOCKET.send(f"Device----[OffLine]".encode())mutex.release()else:HACK_SOCKET.close()mutex.release()breakHCK_SOCK_AND_USERNAME_PORT.remove(HACK_SOCKET)HCK_SOCK_AND_USERNAME_PORT.remove(Hacker_IP[0])HCK_SOCK_AND_USERNAME_PORT.remove(Hacker_IP[1])def main():Hacker = threading.Thread(target=SOCK_Hacker,args=(10031,))Device = threading.Thread(target=SOCK_Dev,args=(10030,))Hacker.start()Device.start()if __name__ == '__main__':main()
运行效果图
控制端 Python代码
#!/usr/bin/python3import socketimport sysimport timeimport datetimedef OPTIONS():# OPEN是正转动 CLOSE是反转 Q是断开与服务器的连接 D是将远控设备踢下线CS = input("\n-----#(OPEN||CLOSE|Q|D)>>>")return CSdef main(MoteIP,MotePort):SOCKS = socket.socket(socket.AF_INET, socket.SOCK_STREAM)SOCKS.connect((MoteIP, MotePort))print("[+]正在接入远程主机")print(SOCKS.recv(1024).decode())while True:CS = OPTIONS()if "OPEN" in CS:SOCKS.send(b'HACK') # o 6F # c 63print("[+]发送运行指令成功!")elif "CLOSE" in CS:SOCKS.send(b'STOP') # o 6F # c 63print("[+]发送停止指令成功!")elif "Q" in CS:SOCKS.send(b'EXIT')print("[-]准备关闭会话")print("[+]服务器返回了一条消息:",SOCKS.recv(1024).decode())sys.exit(0)elif "D" in CS:SOCKS.send(b'DEV')print("[-]准备远程关闭设备")print("[+]服务器返回了一条消息:", SOCKS.recv(1024).decode())else:continueprint("[+]服务器返回了一条消息:", SOCKS.recv(1024).decode())if __name__ == '__main__':main("这里输入服务器IP",int(10031))
效果演示
在此之前应该开放出入站端口，否则会连不上
连接服务器
python3 Connect.py
服务器端接监听控制者连接后显示效果
python3 Service.py
将4G卡取出插入SIM900A模块，并将设备上电准备连接服务器
服务器端接监听设备连接后显示效果(设备上线)
OLED显示屏显示连接成功
在电机上定一个A点
控制方发送命令，服务器返回设备的在线状态
服务器收到来自控制方的信息,并执行命令
受控端收到信号并执行，移动至点B，旋转夹角约30°
视频效果
