目录 start

  1. 1, 正则表达式
    1. 1, 常见的正则表达式符号和特殊字符
  2. 2, 网络编程
    1. 1, 套接字
      1. 1, 地址家族(address family)
    2. 2, socket模块
    3. 3, 实现连接
      1. 1, TCP连接
  3. coding: utf-8
  4. 创建服务器套接字
  5. 套接字与地址绑定
  6. 监听连接
  7. 服务器无限循环
  8. coding: utf-8
  9. 创建客户端套接字
  10. 尝试连接服务器
  11. 通信循环
  12. 关闭客户端套接字
    1. [2, UDP连接](#2-udp连接)
    
  13. coding: utf-8
  14. 创建服务器套接字
  15. 绑定服务器套接字
  16. 服务器无限循环
  17. coding: utf-8
  18. 创建客户端套接字
  19. 通信循环
  20. 关闭客户端套接字
  21. 3、线程
    1. 1、thread模块
    2. 2、threading模块
      1. 1、Thread类

目录 end|2019-10-19 17:04|


1, 正则表达式

1, 常见的正则表达式符号和特殊字符

符号 描述 示例
literal 匹配文本字符串的字面值literal foo
`re1 re2` 匹配正则表达式re1或re2 foo bar
. 匹配任意字符(除了\n之外) b.b
^ 匹配字符串其实部分 ^Dear
$ 匹配字符串终止部分 /bin/*sh$
* 匹配0次或者多次前面出现的正则表达式 [A-Za-z0-9]*
+ 匹配1次或者多次前面出现的正则表达式 [a-z]+.com
? 匹配0次或者1次前面出现的正则表达式 goo?
{N} 匹配N次前面出现的正则表达式 [0-9]{3}
{M,N} 匹配M~N次前面出现的正则表达式 [0-9],[A-Za-z]
[…] 匹配来自字符集的任意单一字符 [aeiou]
[..x-y..] 匹配x~y范围中的任意单一字符 [0-9],[A-Za-z]
[^…] 不匹配此字符集中出现的任意一个字符, 包括某一范围内的字符(如果在此字符集中出现) [^aeiou],[^A-Za-z0-9]
`(* + ? {})?` 用于匹配上面频繁出现/重复出现符号的非贪婪版本(*, +, ?, {}) .*?[a-z]
(…) 匹配封闭的正则表达式,然后另存为子组 ([0-9]{3})?.f(00 u)bar
\d 匹配任何十进制数字,与[0-9]一致(\D与\d相反, 不匹配任何分数型的数字) data\d+.txt
\w 匹配任何字母数字字符, 与[A-Za-z0-9_]相同 (\W相反) [A-Za-z_]\w+
\s 匹配任何空格字符, 与[\n\t\r\v\f]相同(\S与之相反) of\sthe
\b 匹配单词边界 (\B与之相反) \bThe\b
\N 匹配以保存的子组 (参见 (…)) price:\16
\c 逐字匹配任何特殊字符c (即, 仅按照字面意义匹配, 不匹配特殊含义) \.,\\,\*
\A(\Z) 匹配字符串的启始 (结束) (另见 ^和$) \ADear

2, 网络编程

1, 套接字

1, 地址家族(address family)

  • 基于文件

    • AF_LOCAL 或 AF_UNIX
      -基于网络
      -AF_INET 或 AF_INET6

    2, 面向连接和无连接的套接字

    -面向连接的套接字

    • SOCK_STREAM

    -无连接的套接字

    • SOCK_DGRAM

2, socket模块

  • 一般语法

    from socket import *
    socket(socket_family, socket_type, protocol=0)
    protocol通常省略, 默认为0

    -套接字对象内置方法

方法 描述
服务器套接字
s.bind() 将地址(主机名, 端口号对)绑定到套接字上
s.listen() 设置并启动TCP监听器
s.accept() 被动接受TCP客户端连接, 一直等待直到连接到达(阻塞)
客户端套接字方法
s.connect() 主动发起TCP服务器连接
s.connect_ex() connect()的扩展版本, 此时会以错误码的形式返回问题, 而不是抛出异常
普通套接字方法
s.recv() 接受TCP消息
s.recv_into() 接受TCP消息到指定的缓冲区
s.send() 发送TCP消息
s.sendall() 完整的发送TCP消息
s.recvfrom() 接受UDP消息
s.recvfrom_into() 接受UDP消息到指定的缓冲区
s.sendto() 发送UDP消息
s.getpeername() 接受到套接字(TCP)的远程地址
s.getsockname() 当前套接字的地址
s.getsockopt() 返回给定套接字选项的值
s.setsockopt() 设置给定套接字选项的值
s.shutdown() 关闭连接
s.close() 关闭套接字
s.detach() 在未关闭文件描述符的情况下关闭套接字, 返回文件描述符
s.ioctl() 控制套接字的模式(仅支持Windows)
面向阻塞的套接字方法
s.setblocking() 设置套接字的阻塞或非阻塞模式
s.settimeout() 设置阻塞套接字操作的超时时间
s.gettimeout() 获取套接字操作的超时时间
面向文件的套接字方法
s.fileno() 套接字的文件描述符
s.makefile() 创建与套接字关联的文件对象
数据属性
s.family 套接字家族
s.type 套接字类型
s.proto 套接字协议

3, 实现连接

1, TCP连接

  • 服务器
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
# coding: utf-8
from socket import *
from time import ctime

HOST = ''
PORT = 21567
BUFSIZ = 1024
ADDR = (HOST, PORT)

# 创建服务器套接字
s = socket(AF_INET, SOCK_STREAM)
# 套接字与地址绑定
s.bind(ADDR)
# 监听连接
s.listen(5)
# 服务器无限循环
while True:
print '等待连接...'
# 接受客户端连接
tcpCliSock, addr = s.accept()
print '... 连接: ', addr

# 通信循环
while True:
# 接受消息
data = tcpCliSock.recv(BUFSIZ)
if not data:
break
# 发送消息
tcpCliSock.send('[%s] %s' % (ctime(), data))

# 关闭客户端套接字
tcpCliSock.close()
  • 客户端
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
# coding: utf-8
from socket import *

HOST = 'localhost'
PORT = 21567
BUFSIZ = 1024
ADDR = (HOST, PORT)

# 创建客户端套接字
s = socket(AF_INET, SOCK_STREAM)
# 尝试连接服务器
s.connect(ADDR)

# 通信循环
while True:
# 输入信息
data = raw_input('> ')
if not data:
break
# 发送信息
s.send(data)
# 接受信息
data = s.recv(BUFSIZ)
if not data:
break
print data

# 关闭客户端套接字
s.close()

2, UDP连接

  • 服务器
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
# coding: utf-8
from socket import *

HOST = ''
PORT = 21567
BUFSIZ = 1024
ADDR = (HOST, PORT)

# 创建服务器套接字
s = socket(AF_INET, SOCK_DGRAM)
# 绑定服务器套接字
s.bind(ADDR)

# 服务器无限循环
while True:
print '等待...'
# 接受信息
data, addr = s.recvfrom(BUFSIZ)
# 发送信息
s.sendto('UDP连接: ' , addr)
print 'received:', addr
  • 客户端
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
# coding: utf-8
from socket import *

HOST = 'localhost'
PORT = 21567
BUFSIZ = 1024
ADDR = (HOST, PORT)

# 创建客户端套接字
s = socket(AF_INET, SOCK_DGRAM)

# 通信循环
while True:
data = raw_input('> ')
if not data:
break
# 发送信息
s.sendto(data, ADDR)
# 接受信息
data, ADDR = s.recvfrom(BUFSIZ)
if not data:
break
print data

# 关闭客户端套接字
s.close()

3、线程

Python提供了多个模块来支持多线程,包含thread,threadingQueue等模块, 使用thread和threading模块来创建与管理线程。thread提供了基本的线程和锁定支持。threading提供了更高级别、功能更全面的线程管理。Queue模块可用来创建一个队列数据结构,用于在多线程之间进行共享。对于多线程推荐使用threading而不是thread

1、thread模块

  • 函数与锁对象
函数/方法 描述
thread模块的函数
start_new_thread(function, args, kwargs=None) 派生一个新的线程,使用给定的args和kwargs来执行function。该函数必须包含两个参数,即函数名与相对应的参数,及时不需要参数,也要传递一个空元组
allocate_lock() 分配LockType锁对象
exit() 退出指令
LockType锁对象的方法
acquire(wait=None) 尝试获取锁对象
locked() 如果获取了锁对象则返回True,否则,返回False
release() 释放锁

2、threading模块

  • threading模块的对象
对象 描述
thread 表示一个执行线程的对象
Lock 锁原语对象(和thread中的锁一样)
RLock 可重入锁对象,是单一线程可以(再次)获得已持有的锁
Condition 条件变量的对象,使得一个线程等待另一个满足特定的条件,如改变状态
Event 条件变量的通用版本,任意数量的线程等待某个事件的发生,在该事件发生后所有线程将被激活
Semaphore 为线程间共享的有限资源提供一个计数器,如果没有可用资源则会被阻塞
BoundedSemaphore 与Semaphore相似,不过它不允许超过初始值
Timer 与Thread相似,不过它要在运行前等待一段时间
Barrier 创建一个障碍,必须到达指定数量的线程后才可以继续

1、Thread类

  • Thread对象的属性和方法
属性 描述
Thread对象数据属性
name 线程名
ident 线程的标识符
daemon 布尔标志,表示这个线程是否为守护线程
Thread对象方法
start() 开始执行该线程
run() 定义线程功能的方法
join(timeout=None) 直至启动的线程终止之前一直挂起;除非给出timeout