Sunbelt Computer Software

PL/B Language Development and Support

sql-notes/src/SafeService.java at master · aweneagle/sql-notes · GitHub

151 lines (127 loc) · 3.16 KB

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

package canal_qbus;

import org.slf4j.Logger;

import org.slf4j.LoggerFactory;

import java.lang.Thread;

import java.util.List;

import javax.json.JsonObject;

import javax.json.JsonArray;

public class SafeService {

final int TRY_TIMES = 4;

private int sleep = 500;

final int ACT_CONN = 0;

final int ACT_CLOSE = 1;

final int ACT_SEND = 2;

final int ACT_RECV = 3;

final int ACT_ACK = 4;

private boolean connAlive = false;

private Session session;

private Msg msg;

private Logger log;

private String name;

public SafeService(Session s, String name)

{

session = s;

connAlive = false;

this.name = name;

log = LoggerFactory.getLogger(SafeService.class);

}

public boolean conn()

{

connAlive = tryAct(ACT_CONN, TRY_TIMES);

return connAlive;

}

public boolean close()

{

if (connAlive) {

boolean succClose = tryAct(ACT_CLOSE, 1);

connAlive = false;

return succClose;

}

return true;

}

public boolean send(Msg msg)

{

this.msg = msg;

//return tryAct(ACT_SEND, TRY_TIMES);

return tryByAutoReconn(ACT_SEND);

}

public boolean ack()

{

//return tryAct(ACT_ACK, 1);

return tryByAutoReconn(ACT_ACK);

}

public boolean reconn()

{

close();

return conn();

}

public Msg recv() throws Exception

{

/*

if (!tryAct(ACT_RECV, TRY_TIMES)) {

throw new Exception("failed to get data from server");

}

*/

tryByAutoReconn(ACT_RECV);

return this.msg;

}

private boolean tryByAutoReconn(int action)

{

while (true) {

if (tryAct(action, 1)) {

return true;

}

tryAct(ACT_CONN, 2);

}

}

private boolean tryAct(int action, int try_times)

{

while (true) {

try {

this.act(action);

return true;

} catch (Exception e) {

error(e);

try_times --;

if (try_times <= 0) {

break;

}

try {

Thread.sleep(sleep);

/* 下一次延长一倍时间 */

sleep += sleep;

} catch (Exception exp) {

sleep = 500;

error(exp);

return false;

}

}

}

sleep = 500;

return false;

}

private void act(int action) throws Exception

{

switch (action) {

case ACT_CONN:

session.conn();

break;

case ACT_CLOSE:

session.close();

break;

case ACT_SEND:

session.send(msg);

break;

case ACT_RECV:

this.msg = session.recv();

break;

case ACT_ACK:

session.ack();

break;

}

}

private void error(Exception e)

{

e.printStackTrace();

}

}