FilesExpand file tree

 master

/

SuperServlet.java

Copy path

Blame

More file actions

Blame

More file actions

Latest commit

 

History

History

History

166 lines (134 loc) · 5.25 KB

 master

/

SuperServlet.java

Copy path

Top

File metadata and controls

• Code
• Blame

166 lines (134 loc) · 5.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

124

125

126

127

128

129

130

131

132

133

134

135

136

137

138

139

140

141

142

143

144

145

146

147

148

149

150

151

152

153

154

155

156

157

158

159

160

161

162

163

164

165

166

package newSocket;

import java.io.IOException;

import java.net.ServerSocket;

import java.net.Socket;

import java.text.SimpleDateFormat;

import java.util.*;

import java.util.Map.Entry;

import newSocket.UserData;

import net.sf.json.JSONObject;

import javax.swing.*;

public class SuperServlet extends Thread {

private static final int port = 8888;

private ServerSocket ss;

private Socket s;

private boolean start = false;

private static volatile Map<String, UserData> client = new HashMap<>();

public static ArrayList<UserData> ppList = new ArrayList<UserData>();

public static void main(String[] args) {

SuperServlet servlet = new SuperServlet();

Thread thread = new Thread(){

@Override

public void run() {

while(true){

System.out.println("true true " + SuperServlet.ppList.size());

// System.out.println();

SuperServlet.ppList.size();

if(ppList.size()>=2){

// JOptionPane.showMessageDialog(null, ppList.size() + "");

System.out.println("队友已匹配");

UserData data1 = ppList.get(0);

UserData data2 = ppList.get(1);

// 得到id1和id2

String id1 = data1.getUserId();

String id2 = data2.getUserId();

// 给data1和data2分配战斗对象

data1.isMatch = true;

data1.setEnemyId(id2);

data1.setEnemy(data2.getName());

data2.isMatch = true;

data2.setEnemyId(id1);

data2.setEnemy(data1.getName());

// 给data1 和data2 改变状态 2是已经开始对战了

data1.setStatus("2");

data2.setStatus("2");

//随机分配先后手

Random random = new Random();

int i = random.nextInt(2);

if(i==1) {

data1.setFirst( true);

data2.setFirst(false);

}

else {

data1.setFirst(false);

data2.setFirst(true);

}

// 给对手发送消息

JSONObject jsonObject = new JSONObject();

jsonObject.put("id", "匹配成功");

jsonObject.put("isFirst", data1.isFirst);

// jsonObject.put("e")

jsonObject.put("enemy", data1.getEnemy()); // 发送对方名字

data1.getMsgFormat().send(jsonObject);

JSONObject jsonObject1 = new JSONObject();

jsonObject1.put("id", "匹配成功");

jsonObject1.put("isFirst", data2.isFirst);

jsonObject1.put("enemy", data2.getEnemy());

data2.getMsgFormat().send(jsonObject1);

// 把匹配了的给踢出匹配队列

ppList.remove(0);

ppList.remove(0);

}

}

}

};

thread.start();

servlet.startService();

// thread.interrupt();

}

public SuperServlet() {

try {

ss = new ServerSocket(port);

} catch (IOException e) {

e.printStackTrace();

}

}

/**

* 统一获取接口

* 获取在服务器上客户端集

*/

public synchronized static Map<String, UserData> getClient(){

return client;

}

// 启动的方法

public void startService() {

// LogUtils.init();

this.start = true; // 打开接收的标记

this.start(); // 启动线程

System.out.println("服务已启动！监听端口：" + port);

}

@Override

public void run() {

while (true) {

try {

s = ss.accept();

synchronized (s) {

// 随机分配ID

String userId = Const.getId();

MessageFormat cs = new MessageFormat(s); // 建立传输入数据的线程(服务类)

// 为每个连接的客户端定义一个线程为其服务

Thread th = new Thread(cs);

// 定义用户信息类

UserData ud = new UserData();

ud.setName(userId); // 这里地方可能需要改

ud.setUserId(userId);

ud.setMsgFormat(cs);

ud.setSocket(s);

ud.setThread(th);

// myId == userId

client.put(userId, ud); // 将这个用户保存到服务器中

th.start(); // 启动这个线程

// 将识别ID发给客户端保存

JSONObject responseMsg = new JSONObject();

// Const.ID和Const.MSG是key， 后面是value

responseMsg.put(Const.ID, Const.ID_STATUS_HANDSNAKE);

responseMsg.put(Const.MSG, userId);

cs.send(responseMsg); // 发送消息给客户端

System.out.println("一个客户连接... 在线数量：" + client.size());

}

} catch (IOException e) {

e.printStackTrace();

}

}

}

}