专栏首页python3python socket学习

python socket学习

一、简单实例:

实现客户端向服务端发送的信息,服务器收到信息后加上当前时间再返回给客户端

服务端实现:

#!/usr/bin/python
import socket, traceback, time
host = ''
port = 8000
s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
s.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
s.bind((host, port))
s.listen(1)
while 1:
    try:
        clientsock, clientaddr = s.accept()
    except KeyboardInterrupt:
        raise
    except:
        traceback.print_exc()
        continue
    try:
        print "Got connection from", clientsock.getpeername()
        while 1:
            data = clientsock.recv(4096)
            if not len(data):
                break
            clientsock.sendall("[%s] %s" % (time.ctime(),data))
    except (KeyboardInterrupt, SystemExit):
        raise
    except:
        traceback.print_exc()
try:
    clientsock.close()
except KeyboardInterrupt:
    raise
except:
    traceback.print_exc()

客户端实现:

#!/usr/bin/pythonh
import socket, ssl
host = '192.168.209.128'
port = 8000
s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
s.connect((host, port))
while True:
        data = raw_input('please input data:')
        if not data:
                break
        s.sendall(data)
        data = s.recv(4096)
        print data
ssl_sock.close()

运行测试:

[root@localhost example]# python echoclient1.py

please input data:test python

[Sun Sep 15 14:38:47 2013] test python

please input data:test 1111111111111111111111

[Sun Sep 15 14:38:52 2013] test 1111111111111111111111

please input data:

二、socket 多任务处理

以上代码要实现的功能是实现了,但是当你用多个客户端同时执行向服务器端发送信息的时候,就发现同一时间服务端只能处理一个连接,其他的无法正常返回。这是因为服务端的单线程实现的,当收到一个客户端请求处理的时候,就会进入阻塞状态,无法同时处理多个任务。

为了能够同时为多个客户端服务,需要能够同时处理多个网络连接的方法。可通过三种方法来实现:

forking、threading和异步I/O。

通过threading实现服务端:

#!/usr/bin/python
import socket, traceback, os, sys, time
from threading import *
host = ''
port = 8000
def handlechild(clientsock):
        print "New child", currentThread().getName()
        print "Got connection from", clientsock.getpeername()
        while 1:
                data = clientsock.recv(4096)
                if not len(data):
                        break
                clientsock.sendall("[%s] %s" % (time.ctime(),data))
        clientsock.close()
s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
s.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR,1)
s.bind((host, port))
s.listen(1)
while 1:
        try:
                clientsock, clientaddr = s.accept()
        except KeyboardInterrupt:
                raise
        except:
                traceback.print_exc()
                continue
        t = Thread(target = handlechild, args = [clientsock])
        t.setDaemon(1)
        t.start()

这样就可以让服务器同时处理多个任务了。

三、在服务端和客户端使用ssl

首先创建一个自签名证书:

openssl req -new -x509 -days 365 -nodes -out cert.pem -keyout cert.key

服务端:

#!/usr/bin/python
import socket, ssl, traceback, threading, sys, time
host = ''
port = 443
def Myhandlechild(clientsock):
        print "New child", threading.currentThread().getName()
        print "Got connection from", clientsock.getpeername()
        while 1:
                data = clientsock.recv(4096)
                if not len(data):
                        break
                clientsock.sendall("[%s] %s" % (time.ctime(),data))
        clientsock.close()
s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
s.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
s.bind((host, port))
s.listen(5)
while 1:
        try:
                clientsock, clientaddr = s.accept()
                connsock = ssl.wrap_socket(clientsock, server_side=True,
                                           certfile="cert.pem", keyfile="cert.key")
        except KeyboardInterrupt:
                raise
        except:
                traceback.print_exc()
                continue
        t = threading.Thread(target = Myhandlechild, args = [connsock])
        t.setDaemon(1)
        t.start()

客户端:

#!/usr/bin/pythonh
import socket, ssl
s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
s.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
ssl_sock = ssl.wrap_socket(s,ca_certs="cert.pem", cert_reqs = ssl.CERT_REQUIRED)
ssl_sock.connect(('127.0.0.1', 443))
while 1:
        data = raw_input('input data:')
        if not data:
                break
        ssl_sock.sendall(data)
        data = ssl_sock.recv(4096)
        print data
ssl_sock.close()

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

我来说两句

0 条评论
登录 后参与评论

相关文章

  • Python_冒泡排序

    从小到大的排序:(最前面的数和一步步和后面的数比较,如果大于则交换,如果不大于则继续循环)

    py3study
  • Python算法题----列表去重

    有这样一个列表[1, 1, 1, 2, 3, 3, 2, 4, 3, 4, 5, 5, 5, 6, 7, 8, 9, 9, 9, 9, 10, 10], 写一个...

    py3study
  • python(实操4):录音文件的读取、

    py3study
  • 机器学习——动手从决策树实现随机森林

    今天是机器学习专题的第26篇文章,我们一起聊聊另外一个集成学习模型,它就是大名鼎鼎的随机森林。

    TechFlow-承志
  • 声明性数据基础设施为数据驱动企业提供动力

    大数据、人工智能/ML和现代分析技术已经渗透到商业世界,成为企业战略的关键元素,以更好地服务客户、更快地创新和保持领先的竞争。数据是所有这些的核心。在本博客中,...

    CNCF
  • 如何从零开始,形成自己的模块化思维方式?

    计算机这东西不是凭空出现的,它是为了解决一些实际的问题,有很多时候是对现实世界的模拟。遇到问题时,经常会有人说,要有大局观,要具体问题具体分析,也可以牵强的解释...

    web前端教室
  • 独家 | 用pandas-profiling做出更好的探索性数据分析(附代码)

    探索性数据分析已失势,Pandas-profiling万岁!用更省力的办法完美呈现你的数据。

    数据派THU
  • 2019医疗大数据企业排行榜

    近日,互联网周刊发布“2019医疗大数据企业排行榜”,一起来看一下哪些公司上榜了?

    华章科技
  • 大数据爆破之年:在这5个领域“掘金”最靠谱

    时下最热概念“大数据”,作为一个行业专业术语,充斥着网络报纸。显然,我们已经站在了一个时代的转折点,互联网全球化、移动设备普及化、云计算存储低成本化、物质世界网...

    华章科技
  • 微信热补丁Tinker项目组的特别访谈

    前不久,微信开源了其Android热补丁框架Tinker。 Tinker项目地址: https://github.com/Tencent/Tinker(点击文末...

    腾讯开源

扫码关注云+社区

领取腾讯云代金券