python MySQLdb、socket与进线程

1 centos下 安装MySQLdb模块

a 首先需要先安装 setuptool
b yum install -y mysql_devel 头文件
c yum install -y python_devel 头文件

cd MySQLdb
python setup.py build
python setup.py install

1.1、数据库连接MySQLdb提供了connect方法用来和数据库建立连接,接收数个参数,返回连接对象：conn=MySQLdb.connect(host="localhost",user="root",passwd="jb51",db="test",charset="utf8") #建议使用键值字典形式，这样不用害怕顺序问题比较常用的参数包括:host:数据库主机名.默认是用本地主机user:数据库登陆名.默认是当前用户passwd:数据库登陆的秘密.默认为空db:要使用的数据库名.没有默认值port:MySQL服务使用的TCP端口.默认是3306charset:数据库编码commit() 提交rollback() 回滚close() 关闭连接cursor()返回游标,自动开启一个事务后者使用 autoCommit(false)关闭自动提交1.2、cursor方法执行与返回值//执行单条sql语句,接收的参数为sql语句本身和使用的参数列表,返回值为受影响的行数execute(self, query, args)//接收全部的返回结果行.fetchall(self)//接收size条返回结果行.如果size的值大于返回的结果行的数量,则会返回cursor.arraysize条数据fetchmany(self, size=None)//返回一条结果行fetchone(self)//这是一个只读属性，并返回执行execute()方法后影响的行数rowcount2 socketa 创建 sk = socket.socket();#sk.setblocking(0) 非阻塞,accept和recv时一旦无数据，则报错b 绑定 sk.bind(('localhost,8080')) 在AF_INET下，以元组（host,port）的形式表示地址c 监听队列 sk.listen(back) 开始监听传入连接。backlog指定在拒绝连接之前，可以挂起的最大连接数量d connect,address = sk.accept() 接收TCP 客户的连接（阻塞式）等待连接的到来,返回连接对象及地址e 连接 sk.connect(address)f 接收数据 sk.recv(bufsize) 接收数据大小g 发送数据 sk.send(string)h 关闭 sk.close()server:

#!/usr/bin/env python
# -*- coding:utf-8 -*-

import socket

ip_port = ('127.0.0.1',8080)

sk = socket.socket()
sk.bind(ip_port)
sk.listen(5)
flas = true
while flag:
conn,addr = sk.accept()

client_data = conn.recv(1024)
print client_data
conn.sendall('test')

conn.close()

client:

#!/usr/bin/env python
# -*- coding:utf-8 -*-
import socket
ip_port = ('127.0.0.1',8080)

sk = socket.socket()
sk.connect(ip_port)

sk.sendall('来了')

server_reply = sk.recv(1024)
print server_reply

sk.close()

3 线程（threading）start 线程准备就绪，等待CPU调度setName 为线程设置名称getName 获取线程名称setDaemon 设置为后台线程或前台线程（默认）如果是后台线程，主线程执行过程中，后台线程也在进行，主线程执行完毕后，后台线程不论成功与否，均停止如果是前台线程，主线程执行过程中，前台线程也在进行，主线程执行完毕后，等待前台线程也执行完成后，程序停止join 逐个执行每个线程，执行完毕后继续往下执行，该方法使得多线程变得无意义run 线程被cpu调度后自动执行线程对象的run方法

#!/usr/bin/env python
# -*- coding:utf-8 -*-
import threading

def show(arg):
print 'thread'+str(arg)

for i in range(3):
t = threading.Thread(target=show, args=(i,)) #也可以使用继承方式使用多线程，重写run方法
t.start()

print 'main thread stop'

3.1 线程锁

a lock

=

threading.Lock()

lock

=

threading.RLock()可多次获取锁，释放的时候也需要几次

b lock.acquire() 获取锁c lock.release()释放锁3.2 线程事件(事件处理的机制：全局定义了一个“Flag”，如果“Flag”值为 False，那么当程序执行 event.wait 方法时就会阻塞，如果“Flag”值为True，那么event.wait 方法时便不再阻塞)a e = threading.Event()b e.wait() 阻塞c e.set() 设置flag=trued e.clear() 清除set()的值，也就是重置flag3.3 队列a queue = Queue(maxsize) 队列最大值b queue.empty()是否为空c queue.qsize()队列大小d queue.full() 队列是否达到最大值e queue.put()/get()/clear() 添加/获取/清空4 进程（进程各自持有一份数据，默认无法共享数据）

multiprocessing

import

Process

4.1使用方式与线程类似，由于进程数据独立，可使用multiprocessing.Array/Queue/Value/Manager进行数据共同管理，当然也可使用reids4.2 锁机制与线程类似4.3 进程池（multiprocessing.Pool)p = Pool(n) 进程数量res = p.apply_async(func,args,callback)/apply() 异步/同步执行

res.get(time) 获取进程返回数据，time:阻塞时间