manyi/script/car_tcp/many_device_simulate.py

# -*- coding: utf-8 -*-
# !/usr/bin/env python
import datetime
import os
import simplejson as json
import threading
from gevent import socket
import struct
from contextlib import closing
import time
from binascii import *
import crcmod
import random

def get_bytes_from_str(strMsg):
    result = bytes()
    if len(strMsg) % 2 != 0:
        return None
    for ii in range(len(strMsg) / 2):
        temp = int('%s%s' % (strMsg[2 * ii], strMsg[2 * ii + 1]), 16)
        result += struct.pack('B', temp)
    return result

def crc16Add(read):  
    crc16 = crcmod.mkCrcFun(0x18005, rev=True, initCrc=0xFFFF, xorOut=0x0000)
    data = read.replace(" ", "") #消除空格
    readcrcout = hex(crc16(unhexlify(data))).upper()
    str_list = list(readcrcout)
    # print(str_list)
    if len(str_list) == 5:
        str_list.insert(2, '0')  # 位数不足补0，因为一般最少是5个
    crc_data = "".join(str_list) #用""把数组的每一位结合起来  组成新的字符串
    # print(crc_data)
    read = read.strip() + ' ' + crc_data[4:] + ' ' + crc_data[2:4] #把源代码和crc校验码连接起来
    # print('CRC16校验:', crc_data[4:] + ' ' + crc_data[2:4])
    print(read)
    return crc_data[2:4] + crc_data[4:] 

gclient = None
server = '211.159.224.10'
port = 8767
 
def device_receive(devNo):
    
    global devClientDict
    while True:
        try:
            devClient = devClientDict.get(devNo,None)
            if devClient is None:
                time.sleep(10)
                continue
            
            
            data = devClient.recv(1024)  # 这里是字节1k
            if not data:
                time.sleep(0.5)
                continue
             
            data = data.decode()
            print("receive msg:", data)
             
            # 根据服务器下发的指令，构造回复指令
#             cmdType = data[10:12]
#             if cmdType == '12':  # 读取实时监测数据
#                 sendMsg = '68401A0300130000000000000000000000000000000055031412782305010001010200000000000000000000000000000000000000000000000000000000000000005C7A'
#             elif cmdType == '34':  # 运营平台远程控制启机 
#                 sendMsg = '681E1A03003332010200000000111511161555350260320102000000010101008643'
#             elif cmdType == '36':
#                 sendMsg = '680E1A030035320102000000010101002704'
#             elif cmdType == '42':
#                 sendMsg = '68130A0300415503141278230500000000D14B0A540198E2'
#             elif cmdType == '44':
#                 sendMsg = '680D1A030043550314127823050100BD84'
#             elif cmdType == '46':
#                 sendMsg = '680D1A0300455503141278230500000000D14B0A540000000000E14C0A5400'
#             elif cmdType == '48':
#                 sendMsg = '680D1A0300475503141278230500000000D14B0A540100000000E14C0A54005DB3'
#             elif cmdType == '52':
#                 sendMsg = '680C1A030051550314127823050125DC'
#             elif cmdType == '56':
#                 sendMsg = '68121A0300555503141278230598B70E11100314ADAC'
#             elif cmdType == '58':
#                 sendMsg = '680C1A03005755031412782305010E7C'
#             elif cmdType == '62':
#                 sendMsg = '680D1A0300635503141278230501000000000045A5'
#             elif cmdType == '92':
#                 sendMsg = '680C1A030091550314127823050175D9'
#             elif cmdType == '94':
#                 sendMsg = '680C1A03009355031412782305016CB9'
#             elif cmdType == 'A4':
#                 sendMsg = '68251A0300A3550314127823051151116155535026055031412782305010100002010291128018D3C'
#             else:
#                 continue
#             
#             devClient.sendall(sendMsg)
        except Exception, e:
            time.sleep(1)
            continue

# 设备发送消息
def device_send(devNo):
    while True:
        global devClientDict
        crc = crc16Add('2220000001' + devNo + '01020F30322E37302E3130000101010101010101010104')
        strSendMsg = '682220000001' + devNo + '01020F30322E37302E3130000101010101010101010104' + crc
        
        try:
            sendMsg = get_bytes_from_str(strSendMsg)  # 
            devClient = devClientDict.get(devNo,None)
            if devClient is None:
                devClient = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
                devClient.connect((server, port))
                devClientDict[devNo] = devClient
            devClient.sendall(sendMsg)
            time.sleep(random.randint(0,30))
    
        except Exception, e:
            time.sleep(30)
            gclient = None
            print e

import copy
from bson.objectid import ObjectId
from apps.web.device.models import Device
# 　打印收到消息的线程    
obj = Device.objects(devNo = '32010600110308').first()

devNo = '32010600110'
devNos = []
start = 309
for ii in range(300):
    newDevNo = devNo+str(start+ii)
    devNos.append(newDevNo)
    
devClientDict = {}

for devNo in devNos:
    receiveThread = threading.Thread(target=device_send,args=(devNo,))
    receiveThread.setDaemon(True)
    receiveThread.start()
    
    receiveThread = threading.Thread(target=device_receive,args=(devNo,))
    receiveThread.setDaemon(True)
    receiveThread.start()
    
# 登录请求：6822200000013201060011030801020F30322E37302E31300001010101010101010101045AC7
# 不存在的设备登录请求：6822000000015603141278230500020F56342E312E3530000101010101010101010101040CC2
# 心跳请求：680D00010003320106001103080100B83C 680D0001000332010600110308010178FD
# 请求核对计费模型：680D000200055503141278230500014446      680D000200055503141278230500020447
# 请求新的计费模型：680B0200000955031412782305A451
# 订单实时信息：68401A0300130000000000000000000000000000000055031412782305010001010200000000000000000000000000000000000000000000000000000000000000005C7A
# 刷卡启动：6837000400315503141278230501010000000000D14B0A5400000000000000000000000000000000000000000000000000000000000000000070DF
# 订单结束：
# 回复离线统计数据： 68401A0300130000000000000000000000000000000055031412782305010001010200000000000000000000000000000000000000000000000000000000000000005C7A
while True:
    time.sleep(50)
    
print '\nhello'




# import socket
# import sys
#  
# receive_count = 0
#  
# def start_tcp_client(ip,port):
#         ###create socket
#         s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
#  
#         failed_count = 0
#         while True:
#                 try:
#                         print("start connect to server ")
#                         s.connect((ip,port))
#                         break
#                 except socket.error:
#                         failed_count += 1
#                         print("fail to connect to server %d times" % failed_count)
#                         if failed_count == 100: return
#  
#         # send and receive
#         while True:
#                 print("connect success")
#  
#                 #get the socket send buffer size and receive buffer size
#                 s_send_buffer_size = s.getsockopt(socket.SOL_SOCKET, socket.SO_SNDBUF)
#                 s_receive_buffer_size = s.getsockopt(socket.SOL_SOCKET, socket.SO_RCVBUF)
#  
#                 print("client TCP send buffer size is %d" % s_send_buffer_size)
#                 print("client TCP receive buffer size is %d" %s_receive_buffer_size)
#  
#                 receive_count = 0
#                 while True:
#                         msg = raw_input(u"请输入设备主动上报给服务器的消息: ")
#                         s.send(msg.encode('utf-8'))
#                         print("send len is : [%d]" % len(msg))
#                         
#                         msg = s.recv(1024)
#                         print(msg.decode('utf-8'))
#                         print("recv len is : [%d]" % len(msg))
#  
#                         receive_count+= 1
#  
# #                         if receive_count==14:
# #                                 msg = 'disconnect'
# #                                 print("total send times is : %d " % receive_count)
# #                                 s.send(msg.encode('utf-8'))
# #                                 break
#                 break
#  
#         s.close()
#         
# start_tcp_client('127.0.0.1',6000)