python的Socket网络编程 使用模板
相关说明
本文给出的是TCP协议的Socket编程。
其中用了一个dbmanager数据库操作模块,这个模块是我自己定义的,可以在我的另一个文章中找到这个模块的分享。python操作mysql数据库的精美实用模块
服务段完整代码
【如下代码,完全复制,直接运行,即可使用】
import socket import threading import json from tools import dbmanager #这个模块是我自定义的,可以在我的另一个文章中找到这个模块的分享 ################################### ####服务器参数 #################################### HOST = '0.0.0.0' #ip 0.0.0.0 表示本机所有ip地址 PORT = 9905 #端口号 Max_Listen =10 #最大监听数 BUFSIZ = 1024 #每次接收数据长度 ENDMARK = "messageover" #信息结束标记 #################################### ####业务处理函数 #################################### def searchuser(sock, dict_data): the_searchstring = dict_data['par'] #########构造sql语句 sqlstring0 = "SELECT * FROM hr_user WHERE id>0 " if the_searchstring != None and the_searchstring != "": sqlstring0 = sqlstring0 + " AND (username LIKE '%" + the_searchstring + "%')" ########执行数据库查询 data0 = dbmanager.executeSelectAllback(sqlstring0) if data0 == False: message = {'action': 'Error_SqlConnet'} sock.sendall(json.dumps(message).encode("utf-8")) ####发送数据给客户端 return if data0 != None: message = {'action': 'SearchUser_Success'} message['data'] = data0 sock.sendall(json.dumps(message).encode("utf-8")) ####发送数据给客户端 return #################################### ####线程处理函数 #################################### def readRequest(sock, addr): print('Accept new connection from %s:%s...' % addr) allresponse = "" while True: ########接收数据 data = sock.recv(BUFSIZ).decode('utf-8') if len(data): allresponse = allresponse + data if ENDMARK not in allresponse: continue if allresponse == "": break ########处理数据 allresponse =allresponse[:-len(ENDMARK)] dict_data = json.loads(allresponse) action = dict_data['action'] if action == "SearchUser": searchuser(sock, dict_data) #业务处理 break elif action == "SearchCompany": break #业务处理 else: break ########关闭连接 sock.close() print('Connection from %s:%s closed.' % addr) #################################### #程序入口 #################################### if __name__ == "__main__": #####创建一个socket the_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM) # AF_INET指定使用IPv4协议 #SOCK_STREAM指定使用面向流的TCP协议 #####绑定端口 the_socket.bind((HOST, PORT)) #####监听端口 the_socket.listen(Max_Listen) print('Waiting for connection...') while True: # 接受一个新连接 sock, addr = the_socket.accept() # 创建新线程来处理TCP连接 the_thread = threading.Thread(target=readRequest, args=(sock, addr)) the_thread.start() ####################################
客户端完整代码
【如下代码,完全复制,直接运行,即可使用】
import socket import json ############################################################################################# ####参数 ############################################################################################# HOST = '127.0.0.1' PORT = 9905 BUFSIZ = 1024 ENDMARK = "messageover" ############################################################################################# #######请求处理函数 ############################################################################################# def issueRequest(action, par): # 创建一个socket the_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM) # 建立连接: try: the_socket.connect((HOST, PORT)) except: print("服务器连接失败!") return ############################# try: ########发送数据: message = {} message['action'] = action message['par'] = par last_message = json.dumps(message) + ENDMARK # son.dumps()将 Python 对象编码成 JSON 字符串 print(message) the_socket.sendall(last_message.encode("utf-8")) ########接收数据 allresponse = "" while True: response = the_socket.recv(BUFSIZ).decode('utf-8') if len(response): allresponse = allresponse + response continue if allresponse == "": break #######处理数据 dict_data = json.loads(allresponse) # json.loads()将已编码的 JSON 字符串解码为 Python 对象 action = dict_data['action'] if action == "SearchUser_Success": data0 = dict_data['data'] print(data0) break elif action == "Error_SqlConnet": print("数据查询失败!") break else: break except: print("服务器连接异常,数据查询失败!") finally: #######关闭连接 the_socket.close() #################################### #程序入口 #################################### if __name__ == "__main__": the_searchstring ="张三" issueRequest("SearchUser", the_searchstring)
本文如有帮助,敬请留言鼓励。
本文如有错误,敬请留言改进。
低调大师中文资讯倾力打造互联网数据资讯、行业资源、电子商务、移动互联网、网络营销平台。
持续更新报道IT业界、互联网、市场资讯、驱动更新,是最及时权威的产业资讯及硬件资讯报道平台。
转载内容版权归作者及来源网站所有,本站原创内容转载请注明来源。
- 上一篇
给妹子讲python-S01E17函数的基本特征
今天开始,我们来讲讲函数,简而言之一个函数就是将一些语句集合在一起的部件,它们能够不止一次的在程序中运行。函数还能计算出一个返回值,并能够改变作为函数输入的参数,而这些参数在代码运行时也许每次“代入”的值都不相同。函数是python为了代码最大程度的重用和最小化代码冗余而提供的最基本的程序结构。 函数有关的内容主要分为函数的基本概念、作用域以及参数传递,还有一些相关的高级概念,如装饰器。 【妹子说】那这一节我们先学习函数的最基本用法吧 首先我们先学习一下在python中如何去编写一个函数。今天我们先抛出点儿理论:需要注意的是,函数在python中同在C语言中是有所不同的。 第一:def引导一段可执行的代码: def本身是一个可执行的语句,函数此时并不存在,直到python运行了def后,函数才存在,def后面包含的就是函数语句。在典型的操作
- 下一篇
python:用pyinstaller做个排列组合的小工具
排列组合用处很多,所以打算自己做个这个工具: from scipy.special import comb,perm from os import system N=int(input('NumberOfThings:')) k=int(input('NumberOfElementsTaken:')) print('从%d里面取出%d个元素:'%(N,k)) print('排列:') print(perm(N,k,exact=True))#exact T 返回长整,F返回浮点 print('组合:') print(comb(N,k,exact=True)) system('pause') 核心就是两句: from scipy.special import comb,perm print(perm(N,k,exact=True))#exact T 返回长整,F返回浮点 print(comb(N,k,exact=True)) 真方便,于是跑去用pyinstaller打包...... 竟然失败了,若干支持库找不到.........我擦 赶紧写个hello world 打个包,看看是不是pyi...
相关文章
文章评论
共有0条评论来说两句吧...
文章二维码
点击排行
-
Docker使用Oracle官方镜像安装(12C,18C,19C)
- Springboot2将连接池hikari替换为druid,体验最强大的数据库连接池
- CentOS8编译安装MySQL8.0.19
- Docker快速安装Oracle11G,搭建oracle11g学习环境
- SpringBoot2配置默认Tomcat设置,开启更多高级功能
- MySQL8.0.19开启GTID主从同步CentOS8
- CentOS7,8上快速安装Gitea,搭建Git服务器
- Jdk安装(Linux,MacOS,Windows),包含三大操作系统的最全安装
- SpringBoot2编写第一个Controller,响应你的http请求并返回结果
推荐阅读
最新文章
- Springboot2将连接池hikari替换为druid,体验最强大的数据库连接池
- Docker使用Oracle官方镜像安装(12C,18C,19C)
- CentOS6,CentOS7官方镜像安装Oracle11G
- SpringBoot2整合Redis,开启缓存,提高访问速度
- Jdk安装(Linux,MacOS,Windows),包含三大操作系统的最全安装
- SpringBoot2配置默认Tomcat设置,开启更多高级功能
- SpringBoot2整合MyBatis,连接MySql数据库做增删改查操作
- Hadoop3单机部署,实现最简伪集群
- MySQL8.0.19开启GTID主从同步CentOS8
- SpringBoot2编写第一个Controller,响应你的http请求并返回结果