python在线编程实现_Python进阶开发之网络编程,socket实现在线聊天机器人

系列文章

本文目录

.什么是socket&＃xff1f;

说到网络编程&＃xff0c;难免要提到socket&＃xff1f;

那什么是socket呢&＃xff0c;中文名叫"套接字"&＃xff0c;更难理解了吧。

通俗来讲&＃xff0c;socket表示一个网络连接&＃xff0c;通过这个连接&＃xff0c;使得主机间或者一台计算机上的进程间可以通讯。

不管是不同主机&＃xff0c;还是同一主机。既然是通信&＃xff0c;必定有一个发送方&＃xff0c;一个接收方。对应一个客户端&＃xff0c;和一个服务端。

.创建socket客户端

创建socket&＃xff0c;建立连接

import socket

# 指定IPv4协议(AF_INET)&＃xff0c;IPv6协议请使用AF_INET6

# 指定使用TCP协议(SOCK_STREAM)&＃xff0c;UDP协议请使用SOCK_DGRAM

# 参数是一个tuple&＃xff0c;tuple里指定服务器地址(域名或ip)和端口号

&＃39;www.sina.com.cn&＃39;, 80))

发送数据

# 注意这里str格式要遵循HTTP协议标准。

# 注意结尾一定要用 \r\n\r\n

"GET / HTTP/1.1\r\nHost: www.sina.com.cn\r\n\r\n".encode("utf-8"))

接收数据

while True:

# 每次最多接收1k字节

1024)

if d:

# Python3接收到为bytes类型&＃xff0c;要转为str

else:

break

&＃39;&＃39;.join(buffer)

.创建socket服务端

创建socket

import socket

绑定ip和port

# 注意以元组格式传入&＃xff0c;可以是某网卡的公网ip&＃xff0c;或0.0.0.0&＃xff0c;或127.0.0.1

&＃39;127.0.0.1&＃39;, 9999))

监听端口

# 指定等待连接的最大数量

5)

接收数据

while True:

# 接受一个新连接&＃xff0c;阻塞的&＃xff0c;只有接收到新连接才会往下走

# 每一次连接&＃xff0c;都要创建新线程&＃xff0c;否则一次只能处理一个连接

连接处理函数

def tcplink(sock, addr):

while True:

1024)

if data &＃61;&＃61; &＃39;exit&＃39; or not data:

break

&＃39;Hello, %s!&＃39; % data)

.socket工作流程图解

.socket公共函数汇总

发送数据

# 发送TCP数据&＃xff0c;返回值&＃xff1a;发送的字节当量

"data string")

# 完整发送TCP数据&＃xff0c;频繁调用send方法&＃xff0c;确保数据发送完成

"data string")

# 发送UDP数据

"data string",address)

接收数据

# 接收TCP数据&＃xff0c;一次最大只接收1k数据

1024)

# 接收UDP数据&＃xff0c;一次只接收1k数据&＃xff0c;返回值&＃xff1a;数据和发送方ip

1024)

获取socket信息

# 获取远程socket的addr,port

# 获取本地socket的addr,port

获取其他信息

import socket

# 获取当前主机名

# 获取当前主机的ip

# 获取当前socket连接的文件描述符

设置socket

# 设置连接的超时时间

# 设置为非阻塞模式&＃xff0c;默认是0(阻塞)

# 非阻塞下&＃xff0c;accept和recv时一旦无数据&＃xff0c;则报错&＃xff1a;socket.Error

1)

# 设置socket内部参数&＃xff0c;

# 具体有哪些参数&＃xff0c;可以查看socket类的python源码

.实战&＃xff1a;搭建在线聊天机器人

通过上面的学习&＃xff0c;我们知道&＃xff0c;同主机下或不同主机下的两个进程要进行通信(TCP/UDP&＃xff0c;不管是消息传输还是文件传输)&＃xff0c;必定要借助socket这个桥梁。

那接下来&＃xff0c;我们就一起来完成这个实战项目&＃xff1a;在线聊天机器人。

思路&＃xff1a;首先&＃xff0c;客户端和服务端建立socket连接&＃xff0c;然后客户端向服务端发送消息&＃xff0c;服务端接收消息&＃xff0c;并调用 图灵机器人API接口&＃xff0c;获取回复返回给客户端。

在这里&＃xff0c;我们需要先去图灵机器人(http://www.tuling123.com)申请帐号&＃xff0c;并创建机器人应用&＃xff0c;获取授权码。

一切准备就绪&＃xff0c;就可以写我们的代码了。

客户端

import socket

import time

class ChatClient:

def __init__(self, username, port):

"127.0.0.1", port))

def send_msg(self, msg):

"{username}::{msg}".format(username&＃61;self.username,msg&＃61;msg).encode("utf-8"))

def recv_msg(self):

1024)

if data:

"\n【机器人小图】"&＃43;" "&＃43;time.strftime(&＃39;%Y-%m-%d:%H:%M:%S&＃39;,time.localtime(time.time())))

"utf-8"))

return True

return False

def main(self):

1024)

"utf-8"))

"请输入消息&＃xff1a;")

while True:

if self.recv_msg():

"\n我&＃xff1a;")

if msg &＃61;&＃61; "exit":

"聊天室已关闭")

break

if __name__ &＃61;&＃61; &＃39;__main__&＃39;:

"小明", port&＃61;9999)

服务端

import socket

import time

import threading

import requests

import json

class ChatServer:

def __init__(self, port):

# 绑定服务器的ip和端口&＃xff0c;注意以tuple的形式

"0.0.0.0", port))

5)

# 图灵机器人&＃xff0c;授权码

"your tuling robot key"

"正在监听 127.0.0.1 &＃xff1a;{}...".format(port))

def tcplink(self, sock, addr):

# 每次连接&＃xff0c;开始聊天前&＃xff0c;先欢迎下。

"你好&＃xff0c;欢迎来到机器人聊天器&＃xff01;".encode("utf-8"))

while True:

1024).decode("utf-8")

"::")[0]

"::")[1]

if msg &＃61;&＃61; "exit":

break

if msg:

"【"&＃43;username&＃43;"】 "&＃43;time.strftime(&＃39;%Y-%m-%d:%H:%M:%S&＃39;,time.localtime(time.time())))

"utf-8"))

"与 {} 结束聊天&＃xff01;".format(username))

def get_response(self, info):

# 调用图灵机器人API

&＃39;http://www.tuling123.com/openapi/api?key&＃61;&＃39; &＃43; self.key &＃43; &＃39;&info&＃61;&＃39; &＃43; info

&＃39;utf-8&＃39;

return jd[&＃39;text&＃39;]

def main(self):

while True:

if __name__ &＃61;&＃61; &＃39;__main__&＃39;:

9999)

将服务端程序跑起来&＃xff0c;然后运行客户端&＃xff0c;看下效果。

至此&＃xff0c;我们看到我们机器人已经正常和我们调侃。