作为学校作业的一部分,我们需要使用Python实现一个非常简单的TCP版本。通信本身是通过UDP套接字完成的。
我的问题在于实现accept(),主要是支持多个客户端。我阅读了很多资料,但找不到任何可以回答我的问题的来源。这是我的代码:
我的问题在于实现accept(),主要是支持多个客户端。我阅读了很多资料,但找不到任何可以回答我的问题的来源。这是我的代码:
# Accepts an incoming connection. This method blocks until an incoming SYN message
# arrives, handles the SYN message and returns the socket.
def accept(self):
if self.state < STCP_STATE_LISTEN:
raise StcpSocketException("Socket not listening")
# Extract syn segment
while True:
syn = stcp_packet.read_from_socket(self.sock)
if syn.syn:
log.debug("(%s,%s) received SYN %s" % (self.local_addr, self.local_port, syn))
break
# TODO allocates the TCP buffers and variables
# Allocate new socket
connection = stcp_socket()
connection.bind(self.local_addr, 0)
connection.remote_addr = syn.srcIp
connection.remote_port = syn.srcPort
connection.change_state(STCP_STATE_SYN_RCVD)
# Send syn ack segment
syn_ack = connection.create_empty_pkt(True, True, False, None, syn.seqNum + 1)
self.seqNum += 1
connection.sock.sendto(syn_ack.pack(), syn.srcIp, syn.srcPort)
log.debug("(%s,%s) sent SYN ACK %s" % (connection.local_addr, connection.local_port, syn_ack))
# Extract last segment in handshake process
while True:
ack = stcp_packet.read_from_socket(connection.sock)
if ack.ack:
log.debug("(%s,%s) received ACK %s" % (connection.local_addr, connection.local_port, ack))
connection.change_state(STCP_STATE_ESTAB)
break
return connection
我的问题:
- 新的套接字应该响应syn数据包,还是旧的(监听)套接字完成3次握手?
- 客户端应该继续向监听套接字发送数据包,然后由新创建的套接字传递,还是客户端应该从syn_ack数据包中获取新套接字的IP和端口,并直接发送数据包?