Python拾忆--多线程的socket服务器

阳光明媚的午后,想想最近要开始从写Java到写Python了,就随手打开电脑来体验一下Python与Java之间的不同吧~

记得我还在上大二的时候,那个时候才开始学Java,最感兴趣的就是Java书最后章节讲的socket套接字那部分,第一次看到同时打开多个黑底白字的shell界面的样子,那么的激动T.T~那个时候还不知道什么是多线程,一个客户端就让其他的客户端不工作了…..那会感觉多线程是我学的最麻烦的地方….那时用了一个下午搞了个多线程的socket程序乐呵呵的玩了好久~~

要说我最讨厌Python什么,那一定是它没有java一个方法中的{},取而代之的居然是缩进….真心好不爽额….吐槽就到这里了T.T,这次看了一下Python的socket教程发现和Java大同小异,依旧是创建连接,客户和服务器通过send和recv方法通信,最后进行关闭,而为了防止一个客户端与服务端连接导致其他客户端挂起的现象,我还特意加上了Python的多线程来保证不会出现这个现象,对于Python的多线程,我更倾向于创建threading.Thread的子类来包装一个线程对象,可能这与我经常写Java有关吧~~更熟悉这种方式,下面就把服务端和客户端的代码贴出来:

#coding=utf-8
import socket
import threading,getopt,sys,string

opts, args = getopt.getopt(sys.argv[1:], "hp:l:",["help","port=","list="])
#设置默认的最大连接数和端口号,在没有使用命令传入参数的时候将使用默认的值
list=50
port=8001
def usage():
    print """
    -h --help             print the help
    -l --list             Maximum number of connections
    -p --port             To monitor the port number
    """
for op, value in opts:
    if op in ("-l","--list"):
        list = string.atol(value)
    elif op in ("-p","--port"):
        port = string.atol(value)
    elif op in ("-h"):
        usage()
        sys.exit()

def jonnyS(client, address):
    try:
    #设置超时时间
        client.settimeout(500)
    #接收数据的大小
        buf = client.recv(2048)
    #将接收到的信息原样的返回到客户端中
        client.send(buf)
    #超时后显示退出
    except socket.timeout:
        print ‘time out‘
    #关闭与客户端的连接
    client.close()

def main():
    #创建socket对象。调用socket构造函数
    #AF_INET为ip地址族,SOCK_STREAM为流套接字
    sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
    #将socket绑定到指定地址,第一个参数为ip地址,第二个参数为端口号
    sock.bind((‘localhost‘, port))
    #设置最多连接数量
    sock.listen(list)
    while True:
    #服务器套接字通过socket的accept方法等待客户请求一个连接
        client,address = sock.accept()
        thread = threading.Thread(target=jonnyS, args=(client, address))
        thread.start()

if __name__ == ‘__main__‘:
    main()

为了防止客户数量过多而造成后面的客户等待,我设置了超时时间,虽然不能从更本解决这个问题,但是可以防止一些客户端白白占用着连接数而不工作,也算是总讨巧的方案了~而且通过传入参数的方式也可以方便的控制监听的端口号和允许最多的连接数,虽然没有考证过系统最多开启多少个进程,不过对于一个练习而言已经足够了,希望有人知道的话欢迎留言告诉我哈~

下面是客户端的:

#coding=utf-8
import getopt,socket,sys,string

opts, args = getopt.getopt(sys.argv[1:], "hi:p:",["help","ip=","port="])
#设置默认的ip地址和端口号,在没有使用命令传入参数的时候将使用默认的值
host="localhost"
port=8001
def usage():
    print """
    -h --help             print the help
    -i --ip               Enter the IP address to connect
    -p --port             Enter the port number to connect
    """
for op, value in opts:
    if op in ("-i","--ip"):
        host = value
    elif op in ("-p","--port"):
        port = string.atol(value)
    elif op in ("-h"):
        usage()
        sys.exit()

def main():
#创建socket对象。调用socket构造函数
#AF_INET为ip地址族,SOCK_STREAM为流套接字
    sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
#设置要连接的服务器的ip号和端口号
    sock.connect((host, port))
#客户端输入一个字符串给服务器
    message = raw_input("inupt:")
    #pdb.set_trace()
    sock.send(message)
    print ‘ServerOupt:‘+ sock.recv(2048)
#关闭与服务器的连接
    sock.close()  

if __name__ == ‘__main__‘:
    main()

客户端就相对简单的多了,很简单的一个读取用户输入,发送给服务器然后接收回来这样一个简单的功能,在设置过编码之后中文什么的也是可以的了~值得注意的就是recw()方法中设置的发送大小,太小的话会报错的~

总体来说和我第一次用Java来实现的时候比起来,现在已经轻松容易的多了,不过也正好可以借此机会温习一下过去的知识了~学而不思则罔,思而不学则殆!

时间: 2024-11-17 00:44:38

Python拾忆--多线程的socket服务器的相关文章

转:Socket服务器整体架构概述

Socket服务器主要用于提供高效.稳定的数据处理.消息转发等服务,它直接决定了前台应用程序的性能.我们先从整体上认识一下Socket服务器,Socket服务器从架构上一般分为:网络层.业务逻辑层.会话层.数据访问层,如图: (图1) (一) 网络层 网络层主要用于侦听socket连接.创建socket.接受消息.发送消息.关闭连接.作为socket通信服务器,网络层的性能相当重要,所以我们在设计网络层时,要着重在以下几方面获得突破:最大连接数.最大并发数.秒处理消息数.如何突破呢?下面我为大家

Python使用TCPServer编写(多线程)Socket服务

SocketServer包对socket包进行了包装(封装),使得创建socket服务非常简单. TCPServer+BaseRequestHandler 使用TCPServer和BaseRequestHandler编写socket服务的样例. #-*- coding:utf-8 -*- from SocketServer import TCPServer, BaseRequestHandler import traceback class MyBaseRequestHandlerr(BaseR

python自动化开发学习-9 socket网络编程

一. 简介 python提供了两个级别访问的网络服务: 低级别的网络服务支持节本的socket,它提供了标准的BSD sockets API,可以访问底层操作系统socket接口的全部方法. 高级别的网络服务模块socketserver,它提供了服务器中心类,可以简化网络服务器的开发. socket介绍 socket通常也称作"套接字",用于描述IP地址和端口,是一个通信链的句柄,应用程序通常通过"套接字"向网络发出请求或者应答网络请求. socket起源于Unix

python之路-----多线程与多进度

一.进程和线程的概念 1.进程(最小的资源单位): 进程:就是一个程序在一个数据集上的一次动态执行过程.进程一般由程序.数据集.进程控制块三部分组成. 程序:我们编写的程序用来描述进程要完成哪些功能以及如何完成: 数据集;则是程序在执行过程中所需要使用的资源: 进程控制块:用来记录进程的外部特征,描述进程的执行变化过程,系统可以利用它来控制和管理进程,它是系统感知进程存在的唯一标志. 进程比线程更早出现,计算机早期处理代码时,使用的是串行的方法,假设计算机在运行A,B,C三个软件,需要A运行完了

python并发编程&多线程(二)

前导理论知识见:python并发编程&多线程(一) 一 threading模块介绍 multiprocess模块的完全模仿了threading模块的接口,二者在使用层面,有很大的相似性 官网链接:https://docs.python.org/3/library/threading.html?highlight=threading#(装B模式加载中…………) 二 开启线程的两种方式  方式一  方式二 三 在一个进程下开启多个线程与在一个进程下开启多个子进程的区别  1 谁的开启速度快  2 瞅

PHP socket 服务器框架集

1.Swoole:重新定义PHP PHP语言的高性能网络通信框架,提供了PHP语言的异步多线程服务器,异步TCP/UDP网络客户端,异步MySQL,数据库连接池,AsyncTask,消息队列,毫秒定时器,异步文件读写,异步DNS查询.Swoole可以广泛应用于互联网.移动通信.企业软件.网络游戏.物联网.车联网.智能家庭等领域. 使用PHP+Swoole作为网络通信框架,可以使企业IT研发团队的效率大大提升,更加专注于开发创新产品. 2.workerman workerman是一个高性能的PHP

多线程静态Web服务器开发小试(java)

多线程静态Web服务器(原创)Java版本 克服内存溢出问题采用缓冲式输出 文件一:HttpWebServerOfLcl.java package com.cn.lcl; import java.io.BufferedReader; import java.io.DataInputStream; import java.io.File; import java.io.FileInputStream; import java.io.IOException; import java.io.Input

Python之路【第九篇】:Python基础(26)——socket server

socketserver Python之路[第九篇]:Python基础(25)socket模块是单进程的,只能接受一个客户端的连接和请求,只有当该客户端断开的之后才能再接受来自其他客户端的连接和请求.当然我 们也可以通过python的多线程等模块自己写一个可以同时接收多个客户端连接和请求的socket.但是这完全没有必要,因为python标准库已经为 我们内置了一个多线程的socket模块socketserver,我们直接调用就可以了,完全没有必要重复造轮子. 我们只需简单改造一下之前的sock

iOS 37班多线程,socket,HTTP,ASIHttpRequest,等面试题总结集合

iOS 37班多线程,socket,HTTP,ASIHttpRequest,等面试题总结集合 博客分类: ASIDownloadCache 设置下载缓存 它对Get请求的响应数据进行缓存(被缓存的数据必需是成功的200请求): [ASIHTTPRequest setDefaultCache:[ASIDownloadCache sharedCache]]; 当设置缓存策略后,所有的请求都被自动的缓存起来.另外,如果仅仅希望某次请求使用缓存操作,也可以这样使用: ASIHTTPRequest *re