socket select 服务端

#coding:utf-8
'''
TLU-Location:    server

Created on 2017年2月14日

@author: erain
'''
from ctypes import *
import struct
import select
import socket
import threading
import binascii
from time import sleep
from Queue import Queue


TLU_LOCATION_SERVER_LISTION_MAX=10
TLU_LOCATION_QUEUE_MAX =51200 #50k



class NetCommu_Header(Structure):

    _fields_=[
               ('pkt_len',c_uint16),
               ('dev_id',c_uint32),
               ('pkt_type',c_uint8),
               ('flags',c_uint8),
               ('dev_type',c_uint8),
               ]

    def get_format(self):
        return '!'+'HIBBB'
    def get_len(self):
        return struct.calcsize(self.get_format())
    def do_pack(self):
        header=struct.pack(self.get_format(),self.pkt_len,self.dev_id,
                    self.pkt_type,self.flags,self.dev_type)
        return header
    def do_unpack(self,header):
        self.pkt_len,self.dev_id,self.pkt_type,self.flags,self.dev_type=struct.unpack(self.get_format(),header)
    def do_showHeader(self):
        print 'pkt_len    =    %x'%self.pkt_len
        print 'dev_id    =    %x'%self.dev_id
        print 'pkt_type    =    %x'%self.pkt_type
        print 'flags    =    %x'%self.flags
        print 'dev_types    =    %x'%self.dev_type



class TLU_LocationServer():
    def __init__(self,ip='192.168.2.244',port=10000):

        self.OnLineClient=[]


        self.serv_sock=socket.socket(socket.AF_INET,socket.SOCK_STREAM)
        self.serv_sock.bind((ip,port))
        self.serv_sock.setblocking(False)
        self.serv_sock.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, True)
        self.serv_sock.listen(TLU_LOCATION_SERVER_LISTION_MAX)
        self.serv_accept_thread=threading.Thread(target=self.server_accept_thread)
        self.serv_accept_thread.start()

    def server_accept_thread(self):
        w_list=[]
        r_list=[]
        err_list=[]

        r_list.append(self.serv_sock)


        while True:
            in_list,out_list,err_list=select.select(r_list, w_list, err_list,1)

            for s in in_list:
                if s is self.serv_sock:
                    sock_clt,addr=s.accept()
# print sock_clt
# print addr
                    queue=Queue(maxsize=TLU_LOCATION_QUEUE_MAX)
                    threading.Thread(target=self.server_recv_thread,args=(sock_clt,queue,)).start()
                    threading.Thread(target=self.do_msg_proccess,args=(sock_clt, queue,)).start()
#
# print sock_clt
# print addr
#             sleep(1)
        pass

    def server_recv_thread(self,sock,queue):

        print sock
        self.OnLineClient.append(sock)
        rlist=[]
        wlist=[]
        errlist=[]
        rlist.append(sock)
        isAlive=True
        while isAlive:
            in_list,out_list,err_list=select.select(rlist, wlist, errlist)
            for s in in_list:
                if s is sock:
                    data=s.recv(1024)
                    if data:
# print data
                        if not queue.full():
                            queue.put(data)
                        #存到队列
                    else:
                        s.close()
                        self.OnLineClient.remove(s)
                        isAlive=False

    def do_msg_proccess(self,sock,queue):
        isRun=True
        while isRun:
            if not queue.empty():
                data=queue.get()
# ============================================================
# 此处做协议解析
#============================================================
                print sock,data
            else:
# print "no data"
                sleep(0.1)
            if sock not in self.OnLineClient:
                print "sock closed"
                isRun=False



'''
    测试Header 数据结构
'''
def testHeader():
    head=NetCommu_Header()
    head.pkt_len=0x1234
    head.dev_id=0x56784329
    head.pkt_type=0x30
    head.flags=0x1
    head.dev_type=0xff
    print binascii.b2a_hex( head.do_pack())

    header=binascii.a2b_hex('123456789123456789')
    print len(header)
    head.do_unpack(header)
    head.do_showHeader()
if __name__=='__main__':

    testHeader()

    serv=TLU_LocationServer('192.168.1.111',20000)
    print "TLU Location Startting"