FilesExpand file tree

master

/

MsgHandle.java

Copy path

Blame

More file actions

Blame

More file actions

Latest commit

 

History

History

History

57 lines (44 loc) · 1.38 KB

master

/

MsgHandle.java

Copy path

Top

File metadata and controls

• Code
• Blame

57 lines (44 loc) · 1.38 KB

Raw

Copy raw file

Download raw file

Open symbols panel

Edit and raw actions

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

package com.modulecode.net.impl;

import com.modulecode.net.IMsgHandle;

import com.modulecode.net.IRequest;

import com.modulecode.net.IRouter;

import lombok.ToString;

import org.apache.logging.log4j.LogManager;

import org.apache.logging.log4j.Logger;

import java.io.IOException;

import java.util.HashMap;

@ToString

public class MsgHandle implements IMsgHandle {

private static final Logger logger = LogManager.getLogger(MsgHandle.class);

HashMap<Integer, IRouter> routers = new HashMap<>();

@Override

public int getHandlerCount() {

return routers.size();

}

@Override

public void doMsgHandler(IRequest request) throws IOException {

int msgID = request.getMsgID();

IRouter iRouter = routers.get(msgID);

if (iRouter != null) {

iRouter.preHandle(request);

iRouter.handle(request);

iRouter.postHandle(request);

}

}

@Override

public void addRouter(int msgID, IRouter router) {

IRouter iRouter = this.routers.get(msgID);

if (iRouter == null) {

routers.put(msgID, router);

logger.info("接口 {} 添加成功!", router);

return;

}

logger.warn("接口 {} 已经被注册!", msgID);

}

@Override

public void startWorkerPool() {

}

@Override

public void sendMsgToTaskQueue(IRequest request) {

}

}