Skip to content

C
car-controlserver
Commit 46db3c45 authored by 957dd's avatar 957dd
Browse files
Options

updatehttp

parent b351dc32
Expand all Hide whitespace changes
Inline Side-by-side
Showing with 201 additions and 14 deletions
Deviceld.txt 0 → 100644
View file @ 46db3c45
controlcar0004
\ No newline at end of file
httpserver.py 0 → 100644
View file @ 46db3c45
import os
import socket
def get_local_ip():
try:
s = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
s.connect(("8.8.8.8", 80))
ip = s.getsockname()[0]
s.close()
return ip
except Exception as e:
print(f"获取本地IP地址时出错: {e}")
return None
def write_to_file(data):
try:
# 打开文件，模式为写入模式（会清空已有内容）
with open("Deviceld.txt", "w", encoding="utf-8") as file:
file.write(data)
print("数据已成功写入 Deviceld.txt")
except Exception as e:
print(f"写入文件时出错: {e}")
def read_from_file():
try:
if os.path.exists("Deviceld.txt"):
with open("Deviceld.txt", "r", encoding="utf-8") as file:
return file.read()
return "文件内容为空。"
except Exception as e:
print(f"读取文件时出错: {e}")
return "无法读取文件内容。"
if __name__ == '__main__':
local_ip = get_local_ip()
if local_ip is None:
print("无法获取本地IP地址，程序退出。")
else:
server_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
server_socket.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
server_address = (local_ip, 8080)
server_socket.bind(server_address)
server_socket.listen(5)
print(f'Server is running on http://{server_address[0]}:{server_address[1]}')
while True:
client_socket, client_address = server_socket.accept()
print(f'Accepted connection from {client_address[0]}:{client_address[1]}')
try:
request_data = client_socket.recv(1024).decode('utf-8')
if not request_data:
continue
request_lines = request_data.split('\n')
request_line = request_lines[0]
method, path, _ = request_line.split(' ')
print(f'Received {method} request for {path}')
if method == "POST" and path == "/submit":
# 从请求体中提取数据
body = request_lines[-1] # 请求体在最后一行
data = body.split('=')[1] if '=' in body else body
# 保存数据到文件
write_to_file(data)
# 返回确认响应
response_body = f"""
<html>
<head><title>数据提交成功</title></head>
<body>
<h1>数据已成功提交！</h1>
<a href="/">返回主页</a>
</body>
</html>
"""
status_code = '200 OK'
elif method == "GET" and path == "/":
# 读取文件内容
file_content = read_from_file()
# 返回 HTML 页面
response_body = f'''
<html>
<head>
<title>简易HTTP服务器</title>
<style>
body {{ font-family: Arial, sans-serif; background-color: #f4f4f9; margin: 0; padding: 0; }}
.container {{ max-width: 600px; margin: 50px auto; padding: 20px;
background: white; border-radius: 8px; box-shadow: 0 4px 6px rgba(0, 0, 0, 0.1); }}
h1 {{ text-align: center; }}
textarea {{ width: 100%; height: 150px; margin: 10px 0;
padding: 10px; border: 1px solid #ccc; border-radius: 4px; resize: none; }}
form {{ margin-top: 20px; }}
input[type="text"] {{ width: 90%; padding: 10px;
margin: 10px 0; border: 1px solid #ccc; border-radius: 4px; font-size: 16px; }}
input[type="submit"] {{ background: #007bff; color: white;
padding: 10px 20px; border: none; border-radius: 4px; cursor: pointer; font-size: 16px; }}
input[type="submit"]:hover {{ background: #0056b3; }}
</style>
</head>
<body>
<div class="container">
<h1>欢迎进入设备管理界面！</h1>
<textarea readonly>{file_content}</textarea>
<form action="/submit" method="post">
<input type="text" name="data" placeholder="请输入一些数据" required>
<input type="submit" value="提交">
</form>
</div>
</body>
</html>
'''
status_code = '200 OK'
else:
response_body = '<h1>404 Not Found</h1>'
status_code = '404 Not Found'
response_headers = (
f'HTTP/1.1 {status_code}\n'
f'Content-Type: text/html; charset=utf-8\n'
f'Content-Length: {len(response_body.encode("utf-8"))}\n'
f'Connection: close\n\n'
)
response = response_headers + response_body
client_socket.sendall(response.encode('utf-8'))
except Exception as e:
print(f'Error handling request: {e}')
error_response = (
'HTTP/1.1 500 Internal Server Error\n'
'Content-Type: text/html; charset=utf-8\n'
'Connection: close\n\n'
'<h1>500 内部服务器错误</h1>'
)
client_socket.sendall(error_response.encode('utf-8'))
finally:
client_socket.close()
log/log.txt
View file @ 46db3c45
This diff is collapsed.
main
View file @ 46db3c45
No preview for this file type
main.c
View file @ 46db3c45
......@@ -21,6 +21,7 @@
#include "delay.h"
#include "opensh.h"
char buffer[15]; // 用于存储文件内容
void *serial_usart1(void *arg)
{
......@@ -111,20 +112,54 @@ void *Mqtt_onnect(void *arg)
return NULL;
}
int main(int argc, char *argv[]) {
char *device_inspect()
{
FILE *file;
int size=0;
while (1) {
file = fopen(filename, "r"); // 以只读模式打开文件
if(argc>=4)
{
TOPIC=argv[1];
TOPIC2=argv[2];
TOPIC3=argv[3];
printf("1:%s,2:%s,3:%s\n",TOPIC,TOPIC2,TOPIC3);
if (file == NULL)
{
printf("文件 %s 打开失败，等待中...\n", filename);
}
else
{
// 尝试读取文件内容
if (fgets(buffer, sizeof(buffer), file) != NULL)
{
// 如果文件内容不为空
fclose(file);
printf("读取到文件内容: %s\n", buffer);
return buffer;
}
else
{
printf("文件为空，等待中...\n");
}
fclose(file);
}
Delay_Ms(1,0); // 等待1秒后再次检查
}
}
int main(int argc, char *argv[]) {
Delay_Ms(60,0);
TOPIC=malloc(21);
TOPIC2=malloc(21);
TOPIC3= malloc(15);
TOPIC3=device_inspect();
//sprintf(TOPIC3,"%s",buffer);
//strcpy(TOPIC3,device_inspect());
sprintf(TOPIC2,"dev2app/%s",TOPIC3);
sprintf(TOPIC,"app2dev/%s",TOPIC3);
printf("1:%s,2:%s,3:%s\n",TOPIC,TOPIC2,TOPIC3);
system("pkill firefox");
Delay_Ms(20,0);
reconnect_4g();
Delay_Ms(30,0);
//reconnect_4g();
gStart=time(NULL);//开始时间戳
......
main.h
View file @ 46db3c45
#ifndef __MAIN_H__
#define __MAIN_H__
#define filename "Deviceld.txt"
pthread_t thread[5];
......
mqtt.c
View file @ 46db3c45
......@@ -28,9 +28,9 @@ unsigned char gvalt[4];
struct mosquitto *mosq;
time_t gStart;
char* TOPIC=NULL;
char* TOPIC2=NULL;
char* TOPIC3= NULL;
char* TOPIC;
char* TOPIC2;
char* TOPIC3;
int mqtt_init()
{
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment