俞泰鑫 2019-09-10 11:36 采纳率: 0%
浏览 1763

基于fork()创建网络并发连接,运行时出现ConnectionRefusedError: [Errno 111] Connection refused

fork()创建网络并发连接,运行时出现ConnectionRefusedError: [Errno 111] Connection refused

#服务端
from socket import *
import os
import signal

HOST = '127,0,0,1'
PORT = 8888
ADDR = (HOST,PORT)

def handle(c):
    while True:
        data = c.recv(1024)
        if not data:
            break
        print(data.decode())
        c.send(b'OK')
        c.close()

s = socket()
s.setsockopt(SOL_SOCKET,SO_REUSEADDR,1)
s.listen(5)

signal.signal(signal.SIGCHLD,signal.SIG_IGN)

print('Listen the port 8888.....')

while True:
    try:
        c,addr = s.accept()
        print('Connect from',addr)  
    except KeyboardInterrupt as e:
        os._exit(0)
    except Exception as e:
        print(e)
        continue   

    pid = os.fork()

    if pid == 0:
        s.close()
        handle(c)
        os._exit(0)
    else:
        c.close()

#客户端
sockfd = socket()  

server_addr = ('127.0.0.1',8888)   
sockfd.connect(server_addr)

while True: 
    msg = input('Msg:')
    if not msg:    
        break
    sockfd.send(msg.encode()) 
    data = sockfd.recv(5)
    print('From server:',data.decode())    

sockfd.close()        
  • 写回答

1条回答 默认 最新

  • 关注
    评论

报告相同问题?

悬赏问题

  • ¥20 关于#硬件工程#的问题,请各位专家解答!
  • ¥15 关于#matlab#的问题:期望的系统闭环传递函数为G(s)=wn^2/s^2+2¢wn+wn^2阻尼系数¢=0.707,使系统具有较小的超调量
  • ¥15 FLUENT如何实现在堆积颗粒的上表面加载高斯热源
  • ¥30 截图中的mathematics程序转换成matlab
  • ¥15 动力学代码报错,维度不匹配
  • ¥15 Power query添加列问题
  • ¥50 Kubernetes&Fission&Eleasticsearch
  • ¥15 報錯:Person is not mapped,如何解決?
  • ¥15 c++头文件不能识别CDialog
  • ¥15 Excel发现不可读取的内容