Chinaunix

标题: 多进程multiprocessing模块关于socket问题 [打印本页]

作者: figofifa 时间: 2014-03-26 14:23
标题: 多进程multiprocessing模块关于socket问题
本帖最后由 figofifa 于 2014-03-29 14:42 编辑

sadfssssssssssssssssssssssssssssssssssss

作者: laike9m 时间: 2014-03-26 20:17
一般会加那个括号吗。。

recever = multiprocessing.Process(target = recv_proc)

复制代码

试试呢？

作者: figofifa 时间: 2014-03-27 10:07
回复 2# laike9m
还是不行。

作者: figofifa 时间: 2014-03-27 11:40
回复 3# figofifa
现在只能执行一个进程，要不发进程，或者收进程，不能两个进程同时执行

作者: figofifa 时间: 2014-03-27 12:23
本帖最后由 figofifa 于 2014-03-27 12:48 编辑

回复 4# figofifa
把括号去掉能执行了，但提示两次socket.error: [Errno 10048]，

代码如下：

def send_proc():
global connection,sock1
print '111111111111111111'
time.sleep(3)
activeTestSequence = 0
while True:
      print '22222222222222222'
      print '【CMPP服务端】:发送链路检测消息'.decode('utf-8')
      activeTestCommandLength = 13
      activeTestCommand = 8
      activeTestSequence = activeTestSequence + 1

      MessageHeader = copy.deepcopy(MessageHeader_CMPP)
      MessageHeader[0].append(activeTestCommandLength)
      MessageHeader[1].append(activeTestCommand)
      MessageHeader[2].append(activeTestSequence)
      connection.send(packBody(MessageHeader))
      time.sleep(5)
      print '33333333333333333333333333333333'

def recv_proc():
global connection,sock1
time.sleep(3)
print '4444444444444444444444444'
while True:
      print '5555555555555555555555'
      total_length_rsp = connection.recv(4)
      print '66666666666666666666666666666666'
      (total_length_rsp,) = struct.unpack('>i', total_length_rsp)
      print total_length_rsp, '-----------------------'
      data_rsp = ''
      data_rsp = connection.recv(total_length_rsp - 4)
      thread_Command_id = decomplieCommandId(data_rsp)
      #如果是链路检测消息，需要解包sequence，放到链路检测队列中去
      if thread_Command_id == 2147483656:
         print '【CMPP服务端端】:收到链路检测消息'.decode('utf-8')

def fork_proc():
print 'aaaaaaaaaaaaaaaaa'
reader = multiprocessing.Process(target = send_proc)
reader.start()
print 'bbbbbbbbbbbbbbbbbb'
recever = multiprocessing.Process(target = recv_proc)
recever.start()
print 'ggggggggggggggggggggggg'

print '-----------------------------'

commandLength = 12 + 1 + 16 + 1
command_id = 2147483649
sequence_number = 2

status = '0'
#加密
m = hashlib.md5()
m.update(status + '\0' * 15)
authenticatorismg = m.digest()
#组包
struct.pack('16s', authenticatorismg)
version = 32

MessageHeader = copy.deepcopy(MessageHeader_CMPP)
CMPP_CONNECT = copy.deepcopy(CMPP_CONNECT_CMPP)

MessageHeader[0].append(commandLength)
MessageHeader[1].append(command_id)
MessageHeader[2].append(sequence_number)
CMPP_CONNECT_RESP_CMPP[0].append(int(status))
CMPP_CONNECT_RESP_CMPP[1].append(authenticatorismg)
CMPP_CONNECT_RESP_CMPP[2].append(version)
CMPP_CONNECT_RESP_CMPP[2].append(version)

myHost = 'xx.xx.xxx.xx'
myPort = 8012
sock1 = socket(AF_INET, SOCK_STREAM)
sock1.bind((myHost, myPort))
sock1.listen(1)

while True:
print 'hhhhhhhhhhhh--------------------'
connection, address = sock1.accept()
sock1.setblocking(0)
print 'zzzzzzzzzzzzzzzz--------------------'
print 'Server connected by', address
while True:
      total_length_rsp = connection.recv(4)
      (total_length_rsp,) = struct.unpack('>i', total_length_rsp)
      print total_length_rsp
      data_rsp = ''
      data_rsp = connection.recv(total_length_rsp - 4)
      thread_Command_id = decomplieCommandId(data_rsp)
      print thread_Command_id
      #如果是登陆请求连接
      if thread_Command_id == 1:
         connection.send(packBody(MessageHeader + CMPP_CONNECT_RESP_CMPP))
         print "okkgggggggg"
         #break
         fork_proc()
connection.close()

报错日志如下：

raceback (most recent call last):
  File "<string>", line 1, in <module>
  File "D:\Python27\lib\multiprocessing\forking.py", line 373, in main
prepare(preparation_data)
  File "D:\Python27\lib\multiprocessing\forking.py", line 488, in prepare
'__parents_main__', file, path_name, etc
  File "C:\Documents and Settings\qimeng.NEUSOFT-74C56BE\PycharmProjects\untitled2\CmppServerFork.py", line 219, in <module>
sock1.bind((myHost, myPort))
  File "D:\Python27\lib\socket.py", line 224, in meth
return getattr(self._sock,name)(*args)
socket.error: [Errno 10048] ͨ

欢迎光临 Chinaunix (http://bbs.chinaunix.net/)