一个client/server架构的程序，都是用的python3.8.9，client跑在ubuntu16上，server在centos7和树莓派3上都试过。
问题描述：原来跑着都一切正常，突然有一天不记得自己修改过什么东东了，然后ssl就各种报错，客户端连不上服务器了。客户端的log文件里看，一直报一个错误EOF occurred in violation of protocol (_ssl.c:1125)，服务器的log文件里看，客户端连接上来立刻就掉线，然后又重连，又掉线...如此反复。
根据网上找的信息，我安装各种包，甚至卸载/重装python，都解决不了问题。最后好好想想出这个问题之前我是改过源代码，没有做过系统操作，所以应该不是各种包的问题，应该还是代码问题。可是我自己看太多遍了，实在看不出问题在哪里了。请高手帮我看看。
以下是代码。
服务器：
# -*- coding:utf-8 -*-
from os import error
from socket import socket
import socketserver, ssl, hashlib, threading
from daemons import daemonizer
import copy
import time
class MyServer(socketserver.BaseRequestHandler):
lock = threading.Lock()
time_out = 20 # 设置超时时间变量
def setup(self):
super().setup()
self.event = threading.Event()
self.log('{} connected'.format(self.client_address))
def finish(self):
self.log('{} disconnected'.format(self.client_address))
def log(self,str):
with open('/myfolder/log', 'a+') as f:
f.write(time.strftime("%Y-%m-%d %H:%M:%S", time.localtime())+' '+str+'\n')
f.close()
def handle_client_request(self, ssl_socket, buf):
#这里做数据处理
return buf
def handle_request(self):
context = ssl.SSLContext(ssl.PROTOCOL_TLSv1_2)
context.load_cert_chain(certfile='/myfolder/cert', keyfile='/myfolder/key')
ssl_socket = context.wrap_socket(self.request, server_side=True)
ssl_socket.settimeout(self.time_out) # 对socket设置超时时间
buf=''
while True:
try:
data=ssl_socket.recv(1024) # when return value is b'',the connect with client is close
except socket.timeout: # 如果接收超时会抛出socket.timeout异常
break
if data:
data_str = bytes.decode(data)
buf += data_str
buf = self.handle_client_request(ssl_socket, buf)
def handle_timeout(self):
self.log('{} disconnected'.format(self.client_address))
@daemonizer.run(pidfile="/myfolder/myserver.pid")
def main():
port = 38658
svr = socketserver.ThreadingTCPServer(('0.0.0.0', port), MyServer)
print('start serving at port', port)
while True:
svr.handle_request()
if __name__ == "__main__":
main()
客户端代码
# -*- coding:utf-8 -*-
import serial
import time
import socket
import ssl
import hashlib
import os
import sys
import signal
import multiprocessing
#import ctypes
from daemons import daemonizer
import requests
def handle(signum, frame):
log("receive a signal {0},is_exit={1}".format(signum, True))
#ssl_sock.shutdown(socket.SHUT_RDWR)
#ssl_sock.close()
def log(str):
with open('/myfolder/log', 'a+') as f:
f.write(time.strftime("%Y-%m-%d %H:%M:%S", time.localtime())+' '+str+'\n')
f.close()
def talk_to_server(ip,port,folder,box_info,share_lock): #跟服务器通信，有问题！！
buf = ''
sock = None
ssl_sock = None
conn_ok = 0
def conn_to_server(ip,port,conn_ok,sock,ssl_sock):
while conn_ok == 0:
try:
log("Connecting to %s:%s" % (ip,port))
ssl_sock = None
sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
ssl_sock = ssl.wrap_socket(sock, ca_certs="/myfolder/cert",cert_reqs=ssl.CERT_REQUIRED)
conn_ok = 0
ssl_sock.connect((ip, port))
except socket.gaierror as e:
log ('Address-related error connecting to server: %s. Keep trying...' % e)
time.sleep(3)
except socket.error as e:
log ('Connection error: %s. Keep trying...' % e) #就是这里，一直报错EOF occurred in violation of protocol (_ssl.c:1125)
time.sleep(3)
else:
log('Conntected')
conn_ok = 1
return conn_ok,sock,ssl_sock
while True:
time.sleep(0.5)
if conn_ok == 0:
conn_ok,sock,ssl_sock = conn_to_server(ip,port,conn_ok,sock,ssl_sock)
try:
#一些代码，就是把com1,com2,网口读到的信息发到server端
ssl_sock.close()
def com1_work(dev,baud,bytesize,parity,stopbits,timeout,box_info,share_lock):
#操作com1读数据，没问题
def com2_work(dev,baud,bytesize,parity,stopbits,timeout,box_info,share_lock):
#操作com2读数据，没问题
def get_duo_rtv(ip,box_info,share_lock):
#操作网口读数据，没问题
@daemonizer.run(pidfile="/myfolder/client.pid")
def main():
box_info = multiprocessing.Manager().dict()
share_lock = multiprocessing.Manager().Lock()
cfg = read_conf()
if cfg == False:
sys.exit(1)
com1 = multiprocessing.Process(target=com1_work, args=('/dev/ttyAMA0', 9600, 8, 'N', 1, 0.25,box_info,share_lock,))
com1.start()
com2 = multiprocessing.Process(target=com2_work, args=('/dev/ttyAMA1', 9600, 8, 'N', 1, 0.25,box_info,share_lock,))
com2.start()
clnt = multiprocessing.Process(target=talk_to_server, args=(cfg['server_ip'],int(cfg['server_port']),cfg['my_site_folder'],box_info,share_lock,))
clnt.start()
req_duo = multiprocessing.Process(target=get_duo_rtv, args=(cfg['duo_ip'],box_info,share_lock,))
req_duo.start()
com1.join()
com2.join()
clnt.join()
req_duo.join()
def handle(signum, frame):
log("receive a signal {0},is_exit={1}".format(signum, True))
com1.terminate()
com2.terminate()
clnt.terminate()
req_duo.terminate()
signal.signal(signal.SIGINT, handle)
signal.signal(signal.SIGTERM, handle)
if __name__ == '__main__':
log('client start')
main()
