Python TCP 服务器套接字

Python TCP server socket

我正在尝试使用 python 打开服务器套接字

我正在使用的代码等待连接并暂停循环,直到尝试执行此行时实现下一个连接 >>

连接,client_address = sock.accept()

但我不需要暂停循环

有什么方法可以让代码在没有连接的情况下跳过这一行继续循环

代码:

服务器

import socket
import sys

# Create a TCP/IP socket
sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)

# Bind the socket to the port
server_address = ('localhost', 10000)
print >>sys.stderr, 'starting up on %s port %s' % server_address
sock.bind(server_address)

# Listen for incoming connections
sock.listen(5)

while True:
    # Wait for a connection
    print >>sys.stderr, 'waiting for a connection'
    connection, client_address = sock.accept()
 
    try:
        print >>sys.stderr, 'connection from', client_address

        # Receive the data in small chunks and retransmit it
        while True:
            data = connection.recv(16)
            print >>sys.stderr, 'received "%s"' % data
            if data:
                print >>sys.stderr, 'sending data back to the client'
                connection.sendall(data)
            else:
                print >>sys.stderr, 'no more data from', client_address
                break
            
    finally:
        # Clean up the connection
        connection.close() 

客户

import socket
import sys

# Create a TCP/IP socket
sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)

# Connect the socket to the port where the server is listening
server_address = ('localhost', 10000)
print >>sys.stderr, 'connecting to %s port %s' % server_address
sock.connect(server_address)


try:
    
    # Send data
    message = 'This is the message.  It will be repeated.'
    print >>sys.stderr, 'sending "%s"' % message
    sock.sendall(message)

    # Look for the response
    amount_received = 0
    amount_expected = len(message)
    
    while amount_received < amount_expected:
        data = sock.recv(32)
        amount_received += len(data)
        print >>sys.stderr, 'received "%s"' % data

finally:
    print >>sys.stderr, 'closing socket'
    sock.close()
 

你想要的是:

  • 在不同的线程中接受套接字
  • 使用异步套接字API

我不太了解 Python,但我很确定它不支持线程,所以它支持异步 IO。快速搜索给我 https://docs.python.org/2/library/asyncore.html

您可以将套接字设置为非阻塞,这将 return 如果没有连接就绪而不是无限期阻塞,则会出现错误

sock.setblocking(False)
try:
    connection, client_address = sock.accept()
except:
    print 'No Connection'