实现思路：客户端（本机）向服务端发送消息；服务端接收消息，并调用图灵机器人API接口，获取回复返回给客户端。
首先需要先去图灵机器人http://www.tuling123.com申请帐号，并创建机器人应用，获取授权码(apikey)；
客户端；
创建socket-->连接服务器-->发送请求-->关闭socket-->结束进程
import socket
import time
def recv_msg(s):
data = s.recv(1024)
if data:
print("\n【机器人小图】"+" "+time.strftime('%Y-%m-%d:%H:%M:%S',time.localtime(time.time())))
print(data.decode('utf-8'))
return True
return False
username = input('input your name:')
port = 9999
s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
s.connect(('127.0.0.1', port))
# 接受服务器的welcom
data = s.recv(1024)
print(data.decode('utf-8'))
msg = input('input msg:')
s.send("{username}::{msg}".format(username=username,msg=msg).encode("utf-8"))
while True:
if recv_msg(s):
msg = input('\n I:')
s.send("{username}::{msg}".format(username=username,msg=msg).encode("utf-8"))
if msg == 'exit':
print('chat is over.')
break
s.close()
- 服务端；
创建socket-->绑定地址端口-->监听-->与客户端建立连接-->处理客户端的请求-->关闭socket
ctrl+c手动结束服务器的进程
import socket
import time
import threading
import requests
import json
def get_response(info):
# 调用图灵机器人API
key = 'caeac376c1084b9ca3bd762244b60ce8'
url = 'http://www.tuling123.com/openapi/api?key=' + key + '&info=' + info
res = requests.get(url)
res.encoding = 'utf-8'
jd = json.loads(res.text)
return jd['text']
# 处理客户端的请求
def tcplink(sock, addr):
sock.send("welcom!".encode('utf-8'))
# 客户端地址
print('client address is:', sock.getpeername())
# 本机（服务端）地址
print('server address is:', sock.getsockname())
while True:
data = sock.recv(1024).decode('utf-8')
# 处理接受到的消息
username, msg = data.split('::')[0], data.split('::')[1]
if msg == 'exit':
break
print(username+':'+time.strftime('%Y-%m-%d:%H:%M:%S',time.localtime(time.time())))
print(msg)
response = get_response(msg)
sock.send(response.encode('utf-8'))
sock.close()
print('the chat with %s is over.' % username)
port = 9999
s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
s.bind(('127.0.0.1', port))
s.listen(5)
print("listening 127.0.0.1:%d, and waiting for connection..." % port)
while True:
sock, addr = s.accept()
t = threading.Thread(target=tcplink, args=(sock, addr, ))
t.start()
-
实现效果
在线聊天机器人
