zoukankan      html  css  js  c++  java
  • Python的socket聊天脚本。

    没有前端,多开了一条线程用于接收信息。

    服务器端:

    # -*- coding:utf-8 -*-
    import socket
    import threading
    
    class Sock_Server:
        def __init__(self):
            self.host = '192.168.1.11'  # 获取主机名
            self.port = 12345  # 端口
            self.ser = socket.socket(socket.AF_INET, socket.SOCK_STREAM)  # 设置模式
            self.ser.bind((self.host, self.port))
            self.ser.listen(5)
            print('等待客户端连接:')
            self.sock, self.addr = self.ser.accept()        # 被动接口客户端连接。
            print(f'客户:{self.addr},已经连接')
    
        def recv(self):           # 接收信息模块
            try:
                while True:
                    recv_info = self.sock.recv(1024)
                    if recv_info:
                        print('
    收到消息:', recv_info.decode())
                        if recv_info == '886':
                            self.sock.close()
                            self.ser.close()
                            print('聊天结束!over')
                            break
            finally:
                self.sock.close()
                self.ser.close()
    
        def send(self):
            try:
                while True:
                    send_info = input('请输入你要发送的内容:')
                    self.sock.send(send_info.encode())
                    if send_info == '886':
                        self.sock.close()
                        self.ser.close()
                        print('聊天结束!over')
                        break
            finally:
                self.sock.close()
                self.ser.close()
    
    
    
    if __name__ == '__main__':
        sock = Sock_Server()
        t1 = threading.Thread(target=sock.recv)
        t1.start()
        sock.send()
    

     客户端:

    # -*- coding:utf8 -*-
    import socket
    import threading
    
    class Sock_Cli:
        def __init__(self):
            self.host = socket.gethostname()  # 获取主机名
            self.port = 12345  # 端口
            self.ser = socket.socket(socket.AF_INET, socket.SOCK_STREAM)  # 设置模式
            self.ser.connect((self.host, self.port))
    
        def recv(self):           # 接收信息模块
            try:
                while True:
                    recv_info = self.ser.recv(1024)
                    if recv_info:
                        print('
    收到消息:', recv_info.decode())
                        if recv_info == '886':
                            self.ser.close()
                            print('聊天结束!over')
                            break
            finally:
                self.ser.close()
    
        def send_info(self):
            try:
                while True:
                    send_info = input('请输入你要发送的内容:')
                    self.ser.sendall(send_info.encode())
                    if send_info == '886':
                        self.ser.close()
                        print('聊天结束!over')
                        break
            finally:
                self.ser.close()
    
    
    if __name__ == '__main__':
        cli = Sock_Cli()
        t1 = threading.Thread(target=cli.recv)
        t1.start()
        cli.send_info()
    

     socket是进程间进行通讯很好的方式。

    整个代码在886输入退出还存在一些问题,不改了。

  • 相关阅读:
    Python的with语句(文件打开方式)
    python代码异常范围检查方法(非常实用)
    python一标准异常总结大全(非常全)
    python里pickle模块
    pyhon文件操作典型代码实现(非常经典!)
    codeblocks中cocos2dx项目添加新的.cpp和.h文件后编译运行的方法
    ubuntu安装cocos2dx
    学习资料整理
    Spring学习笔记--在SpEL中筛选集合
    Spring学习笔记--Spring表达式语言SpEL
  • 原文地址:https://www.cnblogs.com/sidianok/p/12003906.html
Copyright © 2011-2022 走看看