python - 一个文件中两个子进程的套接字通信

Question

我正在交换两个文件(客户端和服务器)之间运行良好的信息，但是我无法将代码实现到一个具有两个子进程的文件中。截至目前，有一个父级生成一个与另一个客户端通信的子级。

我试图将所有套接字绑定(bind)放入子进程中，但无济于事。它只打印前两行。我应该寻找什么？

感谢大家的帮助

server.py(有效)

#!/usr/bin/python           # This is server.py file
import socket               # Import socket module
import random
import os

g=101 # publicly known
p=103 # publicly known

x= random.randint(1,100) # Alice's random number
y= random.randint(1,100) # Bob's random number

aliceSends = (p**x)%g
bobComputes = (aliceSends**y)%g
bobSends = (p**y)%g

s = socket.socket()         # Create a socket object
host = socket.gethostname() # Get local machine name
port = 12345                # Reserve a port for your service.
s.bind((host, port))        # Bind to the port

s.listen(5)                 # Now wait for client connection up to 5.

print 'Qsocket: Using sockets for IPC'
print 'Diffie-Hellman Parameters p=103 and g=101'
print 'Parent: pid= ',os.getpid(),'\n'

while True:
   c, addr = s.accept()     # Establish connection with client.
   print 'Alice Accepted connection from Bob\n'

   if os.fork() == 0:
      #sends first message
      print 'Alice: pid= ',os.getpid(), ', my Parent pid= ',os.getppid()
      print 'Alice Random Secret: ' + str(x)
      print 'Alice Public T: ' + str(aliceSends)
      print 'Alice send to Bob its Public T: ',aliceSends,'\n'
      c.send(str(aliceSends))

      #receieves message
      bobSends = int(c.recv(1024))

      print '<< Alice Got Bob Public T: ',str(bobSends)
      aliceComputes = (bobSends**x)%g
      print 'Alice-to-Bob Shared Secret: << (' + str(aliceComputes) + ') >>'

   c.close()                # Close the connection

print 'Parent: Alice and Bob exited'

client.py(有效)

#!/usr/bin/python           # This is client.py file
import socket               # Import socket module
import random
import os

g=101 # publicly known
p=103 # publicly known

y= random.randint(1,100) # Bob's random number

s = socket.socket()         # Create a socket object
host = socket.gethostname() # Get local machine name
port = 12345                # Reserve a port for your service.

s.connect((host, port))
#receieves first message
print 'Bob: Connected to Alice\n'
print 'Bob: pid= ',os.getpid()
print 'Bob Random Secret: ' + str(y)
bobSends = (p**y)%g
print 'Bob Public T: ' + str(bobSends),'\n'

aliceSends = int(s.recv(1024))
bobComputes = str((aliceSends**y)%g)

print '>> Bob Got Alice Public T: ',str(aliceSends)
print 'Bob-to-Alice Shared Secret: << (' + str(bobComputes) +') >>'
print 'Bob send to Alice its Public T: ',bobSends


#sends message back
s.send(str(bobSends))
s.close                     # Close the socket when done

这是上面的压缩代码，类似于我想要它做的，但它卡在服务器调用上，永远不会到达客户端:cliserv.py(固定)

#!/usr/bin/python           # This is server.py file
import socket               # Import socket module
import random
import os

g=101 # publicly known
p=103 # publicly known

x= random.randint(1,100) # Alice's random number
y= random.randint(1,100) # Bob's random number

aliceSends = (p**x)%g
bobComputes = (aliceSends**y)%g
bobSends = (p**y)%g

s = socket.socket()         # Create a socket object
host = socket.gethostname() # Get local machine name
port = random.randint(0,65500)                # Reserve a port for your service.

print 'Qsocket: Using sockets for IPC'
print 'Diffie-Hellman Parameters p=103 and g=101'
print 'Parent: pid= ',os.getpid(),'\n'

if os.fork() == 0:
   s = socket.socket()
   s.bind((host, port))        # Bind to the port
   s.listen(5)                 # Now wait for client connection up to 5.
   c, addr = s.accept()     # Establish connection with client.

   print 'Alice Accepted connection from Bob\n'

   #sends first message
   print 'Alice: pid= ',os.getpid(), ', my Parent pid= ',os.getppid()
   print 'Alice Random Secret: ' + str(x)
   print 'Alice Public T: ' + str(aliceSends)
   print 'Alice send to Bob its Public T: ',aliceSends,'\n'
   c.send(str(aliceSends))

   #receieves message 'thanks for thanking'
   bobSends = int(c.recv(1024))

   print '<< Alice Got Bob Public T: ',str(bobSends)
   aliceComputes = (bobSends**x)%g
   print 'Alice-to-Bob Shared Secret: << (' + str(aliceComputes) + ') >>'
   c.close()                # Close the connection
elif os.fork() ==0:
   g=101 # publicly known
   p=103 # publicly known

   s = socket.socket()
   s.connect((host, port))
   #receieves first message
   print 'Bob: Connected to Alice\n'
   print 'Bob: pid= ',os.getpid()
   print 'Bob Random Secret: ' + str(y)
   bobSends = (p**y)%g
   print 'Bob Public T: ' + str(bobSends),'\n'

   aliceSends = int(s.recv(1024))
   bobComputes = str((aliceSends**y)%g)

   print '>> Bob Got Alice Public T: ',str(aliceSends)
   print 'Bob-to-Alice Shared Secret: << (' + str(bobComputes) +') >>'
   print 'Bob send to Alice its Public T: ',bobSends


   #sends message back
   s.send(str(bobSends))
   s.close                     # Close the socket when done
else:
   #parent
   os.wait()
   # one child has exited
   os.wait()
   # both children have exited
   print 'Parent: Alice and Bob exited'

输出应该是这样的:

Qsocket: Using sockets for IPC
Diffie-Hellman Parameters p=103 and g=101
Parent: pid=  5462
Alice: pid=  5463  my Parent pid=  5462 

Alice Random Secret: 64
Alice Public T:  79
Alice send to Bob its Public T:  79 

Bob: pid=  5464  my Parent pid=  5462 

Bob Random Secret: 85
Bob Public T: 62

>> Bob Got Alice Public T:  79
Bob-to-Alice Shared Secret: << (36) >>
Bob send to Alice its Public T:  62 

<< Alice Got Bob Public T:  62
Alice-to-Bob Shared Secret: <<(36)>>

Parent: Alice Exited
Parent: Bob Exited

编辑:更新代码，使所有三个版本都能正常工作。

Answer 1

重新发布我在 http://www.reddit.com/r/learnprogramming/comments/1ywkut/python_socket_communication_by_two_children/ 中的回答.

修复代码的步骤是。

1. 摆脱 while 循环。这不是必需的，在 while 循环中使用 fork 会导致 fork 炸弹。
2. 服务器和客户端进程应该使用独立的套接字和网络逻辑。但是，它们应该使用相同的端口号。
3. 父进程应该在结束时调用 os.wait 两次，以确保两个子进程都已退出。