hammer/mainLogic2.py at master · Cheain/hammer · GitHub

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
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
# IDE : PyCharm Community Edition 5.0.3
# Development language : Python 3.5.1
# this is the client main logic used to test the server performance
import random
import select
import threading
import time

import people
import receive
import report

players = []
sockets = []
BUFFSIZE = 1024
playerNum = 200
aGroup = 20
groupNum = int(playerNum / aGroup)


def createPlayer():
    for i in range(playerNum):
        aplayer = people.creatPlayer(i)
        sockets.append(aplayer.sock)
        players.append(aplayer)
        print('-------------------create player %d succeed-------------------' % i)
    print('-------------------------create %d player in players[]-------------------------' % len(players))


def getMsg():
    while True:
        try:
            sock, se, err = select.select(sockets, [], [], 5)
            for re in sock:
                msg = receive.getKind(re.recv(BUFFSIZE))  # recv msg
                players[msg['ID']].choose(msg)  # msg function
        except Exception as e:
            pass


def hit(group):
    while True:
        try:
            aplayer = random.choice(players[(group - 1) * aGroup:group * aGroup])
            print('ID:%d,field:%d,table:%d,mode:%d,ownNick:%s,ownCoin:%d,mateNick:%s,mateCoin:%d,position'
                  % (aplayer.ID, aplayer.field, aplayer.table, aplayer.mode, aplayer.ownNick, aplayer.ownCoin,
                     aplayer.mateNick, aplayer.mateCoin), end="")
            for i in aplayer.egg:
                print(' %d ' % i, end="")
            print('have eggs')
            aplayer.send(report.hitEgg(aplayer.ID, aplayer.table, aplayer.field, random.choice(aplayer.egg)))
            aplayer.time1 = time.time()
            # time.sleep(5)
            # time.sleep(random.uniform(0, 3))
        except Exception as e:
            time.sleep(random.uniform(0, 1))
        finally:
            time.sleep(random.uniform(0, 1))


t1 = threading.Thread(target=createPlayer).start()
for i in range(groupNum):
    t2 = threading.Thread(target=hit, args=(i,)).start()
t3 = threading.Thread(target=getMsg).start()

# for i in range(groupNum):
#    threading._start_new_thread(hit, ())
while True:
    print('············································%d' % len(players))
    time.sleep(10)