FilesExpand file tree

master

/

Server.java

Copy path

Blame

More file actions

Blame

More file actions

Latest commit

 

History

History

History

123 lines (95 loc) · 3.25 KB

master

/

Server.java

Copy path

Top

File metadata and controls

• Code
• Blame

123 lines (95 loc) · 3.25 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

58

59

60

61

62

63

64

65

66

67

68

69

70

71

72

73

74

75

76

77

78

79

80

81

82

83

84

85

86

87

88

89

90

91

92

93

94

95

96

97

98

99

100

101

102

103

104

105

106

107

108

109

110

111

112

113

114

115

116

117

118

119

120

121

122

123

package com.modulecode.net.impl;

import com.modulecode.entity.GinxConfig;

import com.modulecode.net.*;

import com.modulecode.net.funcs.HandleFunc;

import com.modulecode.utils.Global;

import lombok.Data;

import lombok.Setter;

import org.apache.logging.log4j.LogManager;

import org.apache.logging.log4j.Logger;

import java.io.IOException;

import java.net.Inet4Address;

import java.net.ServerSocket;

import java.net.Socket;

public class Server implements IServer {

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

private GinxConfig ginxConfig;

//当前Server的消息管理模块，用来绑定MsgID和对应的处理方法

private IMsgHandle msgHandler;

@Setter

private IDataPack dataPack;

//当前Server的链接管理器

private IConnManager ConnMgr;

public Server() {

this.msgHandler = new MsgHandle();

this.ginxConfig = new GinxConfig();

this.ginxConfig.setHost("0.0.0.0");

this.ginxConfig.setTcpPort(9090);

this.ginxConfig.setName("SERVER");

this.ginxConfig.setMaxConn(5);

this.ginxConfig.setIpVersion("IPV4");

this.ginxConfig.printLogoImageStr();

//如果默认配置文件存在 就直接去覆盖当前配置

if (Global.global.reloadGinxConfig() != null) {

this.ginxConfig = Global.global.reloadGinxConfig();

}

}

//直接去读取指定的json文件

public Server(String configUrl) {

this.msgHandler = new MsgHandle();

this.ginxConfig = Global.global.reloadGinxConfig(configUrl);

this.ginxConfig.printLogoImageStr();

}

@Override

public void start() {

int totalHandler = this.msgHandler.getHandlerCount();

logger.info("[HANDLERS] Now {} register {} handlers:{}", ginxConfig.getName(), totalHandler, msgHandler);

logger.info("[START] Server name: {},listenner at IP: {}, Port {} is starting", ginxConfig.getName(), ginxConfig.getHost(), ginxConfig.getTcpPort());

var cid = 0;

try {

ServerSocket listener = new ServerSocket(ginxConfig.getTcpPort(), 50, Inet4Address.getByName(ginxConfig.getHost()));

for (; ; ) {

//如果有客户端进入则会返回

Socket client = listener.accept();

Connection connection = new Connection(client, cid, msgHandler);

connection.setDataPack(dataPack);

connection.start();

cid++;

}

} catch (IOException e) {

logger.error(e.getMessage());

throw new RuntimeException(e);

}

}

@Override

public void stop() {

}

@Override

public void serve() {

start();

}

@Override

public void addRouter(int msgID, IRouter router) {

msgHandler.addRouter(msgID, router);

}

@Override

public IConnManager getConnMgr() {

return null;

}

@Override

public void setOnConnStart(Runnable runnable) {

}

@Override

public void setOnConnStop(Runnable runnable) {

}

@Override

public void callOnConnStart(IConnection conn) {

}

@Override

public void callOnConnStop(IConnection conn) {

}

@Override

public IDataPack packet() {

return null;

}

}