用Python寫的一個多線程機器人聊天程序

本人是從事php開發的, 近來想通過php實現即時通訊(兼容windows)。后來發現實現起來特別麻煩， 就想到python。聽說這家伙在什么地方都能發揮作用。所以想用python來做通訊模塊。。。所以主要學習pythonn的多線程和tcp連接。

 

但是沒有用過python， 所有在學習python的同時寫個小小的程序 -》 和機器人聊天

 

本程序機器人由【圖靈機器人 http://www.tuling123.com】提供， 把編寫的例子發了出來供初學python的朋友們學習和熟悉。

 

注意：python版本必須為3.x +， 不兼容2.x版本的python

 

文件列表: 

 

main_server.py: 服務端程序，用於接收客戶端的信息， 並返回Jinko回答的話

# tcp server
import socket;
import time;
import threading;
from JinkoRobot import *;

#應用程序入口類
class ApplicationServer:

    #構造函數初始化 socket 
    def __init__(self, host="localhost", port=8005):
        self.connList = [];
        self.socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM);
        self.socket.bind((host, port));
        self.socket.listen(100);
        print("我是Jinko, 我來自[圖靈機器人:http://www.tuling123.com]");
        print("");
        print("趕緊打開客戶端和我聊天吧!");
        self.accept();

    #多線程接受用戶請求
    def accept(self):
        while True:
            connection, address = self.socket.accept();
            # print('connect')
            thread = ChatThread(connection);
            thread.start();

#聊天線程
class ChatThread(threading.Thread):

    def __init__(self, conn):
        threading.Thread.__init__(self);
        self.__connection = conn;

    def run(self):
        while True:
            try:
                recv = self.__connection.recv(8192);
            except:
                break;

            # print("收到:" + recv.decode('utf-8'))
            rebot = JinkoRobot();
            rebot.listenFor(recv.decode('utf-8'));
            answer = rebot.answer();
            # print('say:' + answer)
            self.__connection.send(answer.encode('utf-8'));

ApplicationServer();

 

main_client.py: 客戶端程序， 用於和Jinko發起聊天

import socket;
import time;

sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM);
print("正在和Jinko連線...");
sock.connect(('localhost', 8005));
print("");


while True:
    speak = input("和Jinko說點什么:");

    if speak == "quit":
        break;

    if speak == "":
        continue;

    # print("發送中..." + "("+ speak +")")
    sock.send(speak.encode('utf-8'));
    # print("已發送")

    print("Jinko在思考...");
    answer = sock.recv(8192);
    print("Jinko回復你:" + answer.decode('utf-8'));
    print("");

sock.close();

 

JinkoRobot.py: 它就是Jinko啦啦啦~~

#Jinko Robot
import json;
import urllib.request;
import urllib.parse;

class JinkoRobot:
    
    __answer = '';

    def __init__(self):
        pass;

    #傾聽話語
    def listenFor(self, string):
        self.__answer = self.thinking(string);

    # 思考着
    def thinking(self, string):
        says = urllib.parse.quote_plus(string);
        f = urllib.request.urlopen("http://www.tuling123.com/openapi/api?key=4bc32d41c10be18627438ae45eb839ac&info=" + says);
        json_str = f.read();
        thinkdata = json.loads(json_str.decode('utf-8'));
        f.close();
        
        if(thinkdata['code'] > 40000 and thinkdata['code'] < 40010):
            return "今天Jinko被你問得有點累了, 過會再問吧!";

        if(thinkdata['code'] == 200000):
            return thinkdata['text'] + ", 猛戳這里>>" +  thinkdata['url'];

        if(thinkdata['code'] == 302000) :
            info = thinkdata['text'];

            for content in thinkdata['list']:
                info += "\n\n>" + content['article'] \
                        + "  來源於" + content['source'] \
                        + "  詳細信息請猛戳這里>>" + content['detailurl'];
            
            return info;

        if(thinkdata['code'] == 305000):
            info = thinkdata['text'];

            for key in thinkdata['list']:
                info += "\n\n>" + key + ": 車次>" + content['trainnum'] \
                        + "  從" + content['start'] + "到" + content['terminal'] \
                        + "  發車時間:" + content['starttime'] \
                        + "  到達時間:" + content['endtime'] \
                        + "  詳細信息請猛戳這里>>" + content['detailurl'];
            
            return info;

        return thinkdata['text'];

    #和你交流回答
    def answer(self):
        return self.__answer;

 

運行效果圖:

 

最后我想說下， 我只是python的初學者，沒啥python經驗哈

 

順便提供下zip下載包：http://files.cnblogs.com/files/JinkoWu/ChatWithRobot.zip