码迷,mamicode.com
首页 > 编程语言 > 详细

第一个socket编程(python)

时间:2015-08-28 21:28:23      阅读:408      评论:0      收藏:0      [点我收藏+]

标签:socket   python   linux   

因为要支持服务器端运行,我采用linux,支持多个终端运行,如果直接在IDE上运行不能同时运行服务器端和客户端

1:首先要知道怎么在终端运行python脚本程序

$ chmod a+x helloworld.py
$ ./helloworld.py
Hello World

chmod命令用来 改变 文件的 模式 ,给系统中所有用户这个源文件的执行许可。然后我们可以直接通过指定源文件的位置来执行程序。我们使用./来指示程序位于当前目录。

2:
必须在源程序指定python目录,不知道python执行目录的用which python命令查看
然后加路径加到脚本程序里

#!/usr/bin/python

服务器进程首先要绑定一个端口并监听来自其他客户端的连接。如果某个客户端连接过来了,服务器就与该客户端建立Socket连接,随后的通信就靠这个Socket连接了。

所以,服务器会打开固定端口(比如80)监听,每来一个客户端连接,就创建该Socket连接。由于服务器会有大量来自客户端的连接,所以,服务器要能够区分一个Socket连接是和哪个客户端绑定的。一个Socket依赖4项:服务器地址、服务器端口、客户端地址、客户端端口来唯一确定一个Socket。

但是服务器还需要同时响应多个客户端的请求,所以,每个连接都需要一个新的进程或者新的线程来处理,否则,服务器一次就只能服务一个客户端了。

我们来编写一个简单的服务器程序,它接收客户端连接,把客户端发过来的字符串加上Hello再发回去。

首先,创建一个基于IPv4和TCP协议的Socket:

s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)

然后,我们要绑定监听的地址和端口。服务器可能有多块网卡,可以绑定到某一块网卡的IP地址上,也可以用0.0.0.0绑定到所有的网络地址,还可以用127.0.0.1绑定到本机地址。127.0.0.1是一个特殊的IP地址,表示本机地址,如果绑定到这个地址,客户端必须同时在本机运行才能连接,也就是说,外部的计算机无法连接进来。

端口号需要预先指定。因为我们写的这个服务不是标准服务,所以用9999这个端口号。请注意,小于1024的端口号必须要有管理员权限才能绑定:

监听端口:

s.bind((‘127.0.0.1’, 9999))
紧接着,调用listen()方法开始监听端口,传入的参数指定等待连接的最大数量:

s.listen(5)
print(‘Waiting for connection…’)
接下来,服务器程序通过一个永久循环来接受来自客户端的连接,accept()会等待并返回一个客户端的连接:

while True:
    # 接受一个新连接:
    sock, addr = s.accept()
    # 创建新线程来处理TCP连接:
    t = threading.Thread(target=tcplink, args=(sock, addr))
    t.start()

每个连接都必须创建新线程(或进程)来处理,否则,单线程在处理连接的过程中,无法接受其他客户端的连接:

def tcplink(sock, addr):
    print(‘Accept new connection from %s:%s...‘ % addr)
    sock.send(b‘Welcome!‘)
    while True:
        data = sock.recv(1024)
        time.sleep(1)
        if not data or data.decode(‘utf-8‘) == ‘exit‘:
            break
        sock.send((‘Hello, %s!‘ % data).encode(‘utf-8‘))
    sock.close()
    print(‘Connection from %s:%s closed.‘ % addr)

连接建立后,服务器首先发一条欢迎消息,然后等待客户端数据,并加上Hello再发送给客户端。如果客户端发送了exit字符串,就直接关闭连接。

要测试这个服务器程序,我们还需要编写一个客户端程序:

s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
# 建立连接:
s.connect((‘127.0.0.1‘, 9999))
# 接收欢迎消息:
print(s.recv(1024).decode(‘utf-8‘))
for data in [b‘Michael‘, b‘Tracy‘, b‘Sarah‘]:
    # 发送数据:
    s.send(data)
    print(s.recv(1024).decode(‘utf-8‘))
s.send(b‘exit‘)
s.close()

我们需要打开两个命令行窗口,一个运行服务器程序,另一个运行客户端程序,就可以看到效果了:

完整的服务端程序

#!/usr/bin/python
#encoding: utf-8
import socket
import threading
import time
s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
s.bind((‘127.0.0.1‘, 9999))
s.listen(5)
print(‘Waiting for connection...‘)

def main():
    while True:
    # 接受一个新连接:
        sock, addr = s.accept()
    # 创建新线程来处理TCP连接:
        t = threading.Thread(target=tcplink, args=(sock, addr))
        t.start()


def tcplink(sock, addr):
    print(‘Accept new connection from %s:%s...‘ % addr)
    sock.send(b‘Welcome!‘)
    while True:
        data = sock.recv(1024)
        time.sleep(1)
        if not data or data.decode(‘utf-8‘) == ‘exit‘:
            break
        sock.send((‘Hello, %s!‘ % data).encode(‘utf-8‘))
    sock.close()
    print(‘Connection from %s:%s closed.‘ % addr)

main()

完整的客户端程序

#!/usr/bin/python
#encoding:utf-8
import socket
import threading
s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
# 建立连接:
s.connect((‘127.0.0.1‘, 9999))
# 接收欢迎消息:
print(s.recv(1024).decode(‘utf-8‘))
for data in [‘Michael‘, ‘Tracy‘, ‘Sarah‘]:
    # 发送数据:
    s.send(data)
    print(s.recv(1024).decode(‘utf-8‘))
s.send(b‘exit‘)
s.close()

运行效果
服务器端
技术分享
客户端

技术分享

1)系统启动服务器执行。服务器完成一些初始化操作,然后进入睡眠状态,等待客户机请求。
2)在网络的某台机器上,用户执行客户机程序
3)客户机进行与服务器进程建立一条连接
4)连接建立后,客户机通过网路向服务器发出请求,请求某种服务。
5)服务器接收到客户机的请求后,根据客户机请求的内容进行相应的处理,然后将处理结果返回。
6)服务器断开与客户机的连接,继续睡眠,等待其他客户机的请求。

就是这样。。。。C++网络编程比用python麻烦多了,现在还没整出来。。。QAQ
目前计划是白天搞linux下的网络编程,晚上搞acm…..
哪位大神有Linux下的C++网络编程的好东西可以给我留言哦,万分感激

版权声明:本文为博主原创文章,未经博主允许不得转载。

第一个socket编程(python)

标签:socket   python   linux   

原文地址:http://blog.csdn.net/u013445530/article/details/48058799

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!