lolman dez12345's questions

http.HandleFunc 向客户端请求数据。有没有办法以某种方式指定此方法只能通过 GET 或 POST 工作？

http.HandleFunc("/olock_open/all", func(w http.ResponseWriter, r *http.Request) {
  username, password, ok := r.BasicAuth()
  check_auth := authfunc.CheckAuth(w, username, password, ok)
  if !check_auth {
   return
  }

  for i := 0; i < len(online_locks_list_active); i++ {
   _, err := tcpcommandolock.SendCommandOlock(online_locks_list_active[i].Connection, []byte{0x02, 0x0A, 0x30, 0x51, 0x03, 0x90})
   if err != nil {
    syslogging.LogToSys("Error, can't send command to BU"+online_locks_list_active[i].Address+": "+err.Error(), "Info")
   }
  }
  defer r.Body.Close()
 })```

有一个Go项目。我编译了一个二进制文件，我需要通过带有参数的命令行运行它来找出版本，例如像这样 script_name -version 之后它将程序版本写入控制台并关闭。如何实施？

我通过 Gunicorn 运行 Flask 时遇到以下问题：我有三个脚本。第一个脚本是 Flask 服务器，第二个脚本是 TCP 服务器，第三个脚本运行前两个脚本。如果我通过 app.run() 运行 Flask 服务器脚本，那么一切正常。 Flask 服务器连接到 tsp 服务器，一切正常。但是，如果我通过gunicorn启动它，则会启动多个worker，并且只有其中一个能够连接到TCP服务器。有没有一种方法可以确保所有工作人员都通过 TCP 建立一个连接？也就是说，确保首先执行一些代码来接收数据，与TCP服务器建立TCP连接，然后所有worker从中提取数据并可以访问TCP连接？

Flask服务器

import json
import os
import socket
import time
import requests
from flask import Flask, request, jsonify, render_template
from flask_httpauth import HTTPBasicAuth

app = Flask(name)
auth = HTTPBasicAuth()    
@app.route("/olock_open", methods=['POST'])
@auth.login_required()
def open_lock():
    response = {
        "success": True,
        "error": None
    }
    data = request.get_json()
    if system_data_conf["online_locks_confirm_1c"] == 0:
        if len(data["cells"]) > int(system_data_conf["online_locks_quantity"]) or len(data["cells"]) <= 0:
            response["success"] = False
            response["error"] = "Неверное количество замков"
        else:
            send_data = [data, 'olock_open']
            # print(send_data)
            send_command_bu(send_data)
    return jsonify(response)


system_data_conf = load_config_data()
run_online_locks = True
if system_data_conf["online_locks_enable"] == 1:
    locks_table = load_table_locks()
    try:
        send_message_to_journalctl(
            f'Connecting to ONLINE LOCKS server at address {system_data_conf["host_address_ip"]}:{system_data_conf["online_locks_port"]}')
        client = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
        client.connect((system_data_conf["host_address_ip"], system_data_conf["online_locks_port"]))
    except Exception as error:
        print(error)
        send_message_to_journalctl(error)
        time.sleep(0.1)
# if name == 'main':
#     app.run(threaded=True, debug=False, host=system_data_conf['host_address_ip'],
#                 port=system_data_conf['host_address_port'])

这就是我在第三个脚本中通过 os 运行 Guniccorn 的方式：

os.system('gunicorn --config gunicorn_config.py _internal/flaskserver:app')

这些是gunicorn配置：

import os



workers = int(os.environ.get('GUNICORN_PROCESSES', '2'))

threads = int(os.environ.get('GUNICORN_THREADS', '4'))

# timeout = int(os.environ.get('GUNICORN_TIMEOUT', '120'))

bind = os.environ.get('GUNICORN_BIND', '0.0.0.0:8181')



forwarded_allow_ips = '*'

secure_scheme_headers = { 'X-Forwarded-Proto': 'https' }

请告诉我。我有两个不同的 Python 脚本文件。第一个文件是 Flask 服务器，第二个文件是 TCP 服务器。 Flask 脚本是主文件。启用此参数后，当从同一脚本启动 Flask 时，应启动第二个 TCP 服务器脚本。但由于 TCP 脚本是无穷无尽的，我无法通过子进程来完成它，或者我不明白如何完成。任务是简单地运行这个脚本，而不是进一步监视它，以便它可以自行工作。该怎么办？

服务器烧瓶

#!/usr/bin/sudo python

import time
from flask import Flask, request, jsonify
from flask_restful import Api, Resource, reqparse
import socket
import os
import json
import requests
import logging
from cysystemd import journal
import subprocess
import threading

app = Flask(__name__)


class LoggingSystem:
    def __init__(self):
        self.log = logging.getLogger('ITCService')
        self.log.addHandler(journal.JournaldLogHandler())
        self.log.setLevel(logging.INFO)


def run_online_locks_server():
    subprocess.Popen(

        ['python', 'init.py'], stdout=subprocess.PIPE, stderr=subprocess.PIPE
    )


def check_system_conf():
    start_data = {
        "host_address_ip": '192.168.0.19',
        "host_address_port": 8181,
        "club_software_login": "skud",
        "club_software_pass": "skud1234",
        "club_software_url": "192.168.88.70/skud/",
        "online_locks_port": 9191,
        "online_locks_enable": 1,
        "online_locks_conf": {
            "women": {
                "quantity_locks": 48,
                "hosts_ip_address": ["192.168.0.178"],
                "hosts_port_address": 5001
            },
            "man": {
                "quantity_locks": 48,
                "hosts_ip_address": ["192.168.0.178"],
                "hosts_port_address": 5001
            },
        },
        "debug_flag_enable": 0
    }
    if os.path.isdir('/etc/itclocks'):
        if os.path.exists('/etc/itclocks/itclocks.json'):
            pass
        else:
            file = open('/etc/itclocks/itclocks.json', 'w')
            json.dump(start_data, file, indent=4, sort_keys=True)
            file.close()
    else:
        os.mkdir('/etc/itclocks')
        file = open('/etc/itclocks/itclocks.json', 'w')
        json.dump(start_data, file, indent=4, sort_keys=True)
        file.close()
    return load_config_data()


def load_config_data():
    file = open('/etc/itclocks/itclocks.json', 'r')
    data = json.load(file)
    return data


@app.route("/unlock_all", methods=['GET'])
def open_all_locks():
    client.send('unlock_all'.encode('utf-8'))


@app.route("/check_status", methods=['GET'])
def check_status():
    print('1')
    client.send('check_status'.encode('utf-8'))
    run_listen = True
    while run_listen:
        data = client.recv(512)
        if len(data) == 0:
            pass
        else:
            print(data)
            run_listen = False


@app.route("/unlock_lock", methods=['POST'])
def open_lock():
    data1 = request.get_json()
    client.send("unlock_lock".encode('utf-8'))


if __name__ == '__main__':
    run_online_locks = True
    system_data_conf = check_system_conf()
    if system_data_conf["online_locks_enable"] == 1:
        for i in range(3):
            try:
                run_online_locks_server()
                time.sleep(3)
                client = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
                client.connect(('192.168.0.19', 10000))
                break
            except Exception as error:
                print(error)
                time.sleep(2)

    app.run(threaded=True, debug=True, host=system_data_conf['host_address_ip'],
            port=system_data_conf['host_address_port'])

TCP服务器

#!/usr/bin/sudo python

import socket

print('fff')
server_cu = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
server_cu.connect(('192.168.0.178', 5000))
server = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
# server.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
server.bind(('192.168.0.19', 10001))
server.listen()
conn, addr = server.accept()


def ask_state():
    cmd = [0x02, 0x0A, 0x00, 0x50, 0x03, 0x5F]
    server_cu.send(bytes(cmd))


def process_state(data=None):
    print(data)
    if data is None:
        print("empty packet")
        return False
    if len(data) != 12:
        print("Packet length mismatch")
    if data[0] != 0x02 or data[2] != 0x00 or data[3] != 0x65 or data[10] != 0x03:
        print("invalid packet")
        return False
    board_number = data[1]
    lock_number = 1
    states = []
    for byte_num in range(4, 10):
        for bit_num in range(0, 8):
            state = 1 if data[byte_num] & (1 << bit_num) > 0 else 0
            print(f"B:{board_number}, L{lock_number}, S{state}")
            states.append([board_number, lock_number, state])
            lock_number += 1
    return str(states)


def unlock_all():
    cmd = [0x02, 0x00, 0x30, 0x51, 0x03, 0x86]
    server_cu.send(bytes(cmd))


while True:
    print(2)
    conn, addr = server.accept()
    print(3)
    while True:
        print(4)
        datagram = conn.recv(512)
        print(5)
        if not datagram:
            break
        if datagram == b'check_status':
            cmd = [0x02, 0x00, 0x00, 0x50, 0x03, 0x55]
            ask_state()
            states = None
            data_recv = 0
            while states is None:
                print(9)
                data_recv = server_cu.recv(512)
                print(10)
                if len(data_recv) == 12:
                    print(11)
                    states = False
            print(data_recv)
            conn.send(data_recv)

        if datagram == b'unlock_all':
            print(6)
            unlock_all()

        if b'unlock_lock' in datagram:
            cmd = [0x02, 0x00, 0x30, 0x51, 0x03, 0x86]
            server_cu.send(bytes(cmd))
        conn.sendall(''.encode('utf-8'))
    server.close()

当再次执行 WHILE 循环时，它会停止侦听来自客户端的 RECV() 命令，但脚本会继续工作。我不明白该怎么办。我正在编写此服务器来与另一个设备进行通信，也是通过套接字进行的。如果您从代码中删除“另一个设备”，您仍然会收到相同的错误，并且与其他设备的连接可以正常工作。请各位好心人帮忙！

import socket
import os

SOCKET_FILE = "./echo.socket"

if os.path.exists(SOCKET_FILE):
    os.remove(SOCKET_FILE)

server_cu = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
server_cu.connect(('192.168.0.178', 5000))
server = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
server.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
server.bind(('', 9193))
server.listen()
conn, addr = server.accept()


def ask_state():
    cmd = [0x02, 0x0A, 0x00, 0x50, 0x03, 0x5F]
    # server_cu.send(bytes(cmd))


def process_state(data=None):
    print(data)
    if data is None:
        print("empty packet")
        return False
    if len(data) != 12:
        print("Packet length mismatch")
    if data[0] != 0x02 or data[2] != 0x00 or data[3] != 0x65 or data[10] != 0x03:
        print("invalid packet")
        return False
    board_number = data[1]
    lock_number = 1
    states = []
    for byte_num in range(4, 10):
        for bit_num in range(0, 8):
            state = 1 if data[byte_num] & (1 << bit_num) > 0 else 0
            print(f"B:{board_number}, L{lock_number}, S{state}")
            states.append([board_number, lock_number, state])
            lock_number += 1
    return str(states)


def unlock_all():
    cmd = [0x02, 0x00, 0x30, 0x51, 0x03, 0x86]
    server_cu.send(bytes(cmd))


while True:
    conn, addr = server.accept()
    datagram = conn.recvfrom(512)
    if not datagram:
        break
    if datagram == b'check_status':
        cmd = [0x02, 0x00, 0x00, 0x50, 0x03, 0x55]
        ask_state()
        states = None
        data_recv = 0
        while states is None:
            data_recv = server_cu.recv(512)
            if len(data_recv) == 12:
                states = False
        server.send(data_recv)

    if datagram == b'unlock_all':
        unlock_all()

    if b'unlock_lock' in datagram:
        cmd = [0x02, 0x00, 0x30, 0x51, 0x03, 0x86]
        server_cu.send(bytes(cmd))
    conn.sendall('Nice'.encode('utf-8'))
server.close()
os.remove(SOCKET_FILE)

总的来说，我非常希望能够提供帮助