python+pygame实现五子棋网络对战之一

之前我们系统地描述了五子棋的人机对战了解了五子棋的基本操作例如电脑的应手算法输赢判断等等。那如何实现五子棋的网络对战即人人对战呢这里就用到了套接字socket编程听上去很高级其实无论哪种编程语言实现起来的方法套路都是大同小异的。一、python的套接字socket编程基本概念及操作对基本原理的理解是学习编程的基础。1.1服务端就是一系列硬件或软件为一个或多个客户端服务端服务的用户提供所需的“服务”。它存在唯一目的就是等待客户端的请求经常称之为“监听”并响应客户端为客户端提供服务然后等待更多请求周而复始。1.2套接字是计算机网络数据结构在任何类型的通信开始之前网络应用程序必须创建套接字。socket原意就是插座插口插孔的意思所以可以将它们比作网络插孔没有它将无法进行通信。Python只支持AF_UNIX、AF_NETLINK、AF_TIPC 和 AF_INET 尤其是使用基于网络的AF_INET.套接字三要素IP端口协议。python使用元组保存:ADDR (IP,端口)。协议流式套接字(SOCK_STREAM):用于提供面向连接、可靠的数据传输服务。TCP数据报套接字(SOCK_DGRAM):提供了一种无连接的服务。这个并不能保证数据传输的可靠性数据有可能在传输过程中丢失或出现数据重复且无法保证顺序地接收到数据。UDP1.3python常用对象方法和属性服务器套接字方法bind(ADDR) 将地址(主机名、端口号对)绑定到自接字上listen([backlog]) 设置并启动TCP监听器如果指定backlog则必须至少为0(如果低于0则设置为0);accept() 被动接受TCP客户端连接一直等待直到连接到达(阻塞)客户端套接字方法connect() 主动发起 TCP服务器连接connect_ex() connect()的扩展版本此时会以猎误码的形式返回问题而不是抛出一个异常通用套接字方法recv() 接收 TCP消息recv_into() 接收TCP 消息到指定的缓冲区send() 发送TCP消息sendall() 完整地发送 TCP消息recvfrom() 接收 UDP消息recvfrom_into() 接收 UDP 消息到指定的缓冲区sendto() 发送 UDP消息getpeername() 连接到套接字(TCP)的远程地址getsockname() 当前套接字的地址getsockopt() 返回给定套接字选项的值setsockopt() 设置给定套接字选项的值shutdown() 关闭连接close() 关闭套接字detach() 在未关闭文件描述符的情况下关闭套接字返回文件描述符ioctI() 控制套接字的模式(仅支持Windows)面向阻塞的套接字方法setblocking() 设置套接字的阻塞或非阻塞模式settimeout() 设置阻塞套接字操作的超时时间gettimeout() 获取阻塞套接字操作的超时时间面向文件的套接字方法fileno() 套接字的文件描述符makefile() 创建与套接字关联的文件对象数据属性family 套接字家族AF_UNIX、AF_NETLINK、AF_TIPC 、AF_INETtype 套接字类型 SOCK_STREAM、SOCK_DGRAMproto 套接字协议1.4通常TCP的服务端和客户端创建的步骤如下服务端serverTCP socket() # 创建服务器套接字 serverTCP.bind(HOST,PORT) # 套接字与地址端口绑定 serverTCP.listen() # 监听连接 while True: # 服务器无限循环 clientTCP serverTCP.accept() # 接受客户端连接 comm_loop: # 通信循环 clientTCP.recv()/clientTCP.send() # 对话接收 / 发送 clientTCP.close() # 关闭客户端套接字 serverTCP.close() # 关闭服务器套接字 # 可选客户端clientTCP socket() # 创建客户端套接字 clientTCP.connect(HOST,PORT)# 尝试连接服务器 comm_loop: # 通信循环 clientTCP.send()/clientTCP.recv() # 对话发送 / 接收 clientTCP.close() # 关闭客户端套接字注UDP这里不详细讲解。可以参考下面的示例代码二、下面就是详细的python代码。先执行 server.py,然后执行client.py,就可以看到TPC/UDP简单的通信效果了。server.pyimport socket from time import ctime import json import time HOST PORT 9001 ADDR (HOST, PORT) BUFFSIZE 1024 MAX_LISTEN 5 def tcpServer(): # TCP服务 with socket.socket(socket.AF_INET, socket.SOCK_STREAM) as s: # 绑定服务器地址和端口 s.bind(ADDR) # 启动服务监听 s.listen(MAX_LISTEN) print(等待用户接入......) while True: # 等待客户端连接请求,获取connSock conn, addr s.accept() print(远端客户:{} 接入系统.format(addr)) with conn: while True: print(接收请求信息......) # 接收请求信息 data conn.recv(BUFFSIZE) print(data%s % data) print(接收数据{%r}.format(data.decode(utf-8))) # 发送请求数据 conn.send(data.encode(utf-8)) print(发送返回完毕) s.close() # 创建UDP服务 def udpServer(): # 创建UPD服务端套接字 with socket.socket(socket.AF_INET, socket.SOCK_DGRAM) as s: # 绑定地址和端口 s.bind(ADDR) # 等待接收信息 while True: print(UDP服务启动准备接收数据...) # 接收数据和客户端请求地址 data, address s.recvfrom(BUFFSIZE) if not data: break print(接收请求信息{}.format(data.decode(utf-8))) s.sendto(bThis is a udp server!, address) s.close() if __name__ __main__: while True: choice input(请选择 t-tcp 或 u-udp:) if choice ! t and choice ! u: print(请输入 t 或 u,不接受其他字符) continue if choice t: print(TCP服务端) tcpServer() else: print(UDP服务端) udpServer()client.pyimport socket from time import ctime HOST localhost PORT 9001 ADDR (HOST, PORT) ENCODING utf-8 BUFFSIZE 1024 def tcpClient(): # 创建客户套接字 with socket.socket(familysocket.AF_INET, typesocket.SOCK_STREAM) as s: # 尝试连接服务器 s.connect(ADDR) print(连接服务成功) # 通信循环 while True: inData input(请输入内容q退出:) if inData q: break # 发送数据到服务器 inData [{}]:{}.format(ctime(), inData) s.send(inData.encode(ENCODING)) print(发送成功) # 接收返回数据 outData s.recv(BUFFSIZE) print(返回数据信息{!r}.format(outData)) # 关闭客户端套接字 s.close() def udpClient(): # 创建客户端套接字 with socket.socket(socket.AF_INET, socket.SOCK_DGRAM) as s: while True: # 发送信息到服务器 data input(请输入内容quit退出:) if data quit: break data [{}]:{}.format(ctime(), data) s.sendto(data.encode(utf-8), ADDR) print(send success) # 接收服务端返回信息 recvData, addrs s.recvfrom(BUFFSIZE) print(接收到的信息 : {}.format(recvData.decode(utf-8))) # 关闭套接字 s.close() if __name__ __main__: while True: choice input(请选择 t-tcp 或 u-udp 或 q-quit:) if choice q: break if choice ! t and choice ! u: print(请输入 t 或 u,不接受其他字符!) continue if choice t: print(TCP服务端) tcpClient() else: print(UDP服务端) udpClient()把这两个代码复制执行一下看看效果。待续.....pythonpygame实现五子棋网络对战之二