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
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
| package main
import (
"fmt"
"io"
"io/ioutil"
"log"
"net/http"
"os"
"os/exec"
"regexp"
"strings"
"time"
colorable "github.com/mattn/go-colorable"
"github.com/sirupsen/logrus"
)
var (
ch = make(chan int)
IDocViewUrl = "https://view.xbongbong.com/"
// 探活时间间隔
interval = time.Second * 30
Sum int
pidSlice = []int{}
ticker = time.NewTicker(interval)
)
func init() {
logrus.SetFormatter(&logrus.TextFormatter{ForceColors: true})
logrus.SetOutput(colorable.NewColorableStdout())
}
func main() {
// 启动延时。。×
/* tick := time.Tick(1 * time.Second)
for countdown := 10; countdown > 0; countdown-- {
fmt.Printf("\r%2d", countdown)
<-tick
} */
fileWriter, err := os.OpenFile("log.txt", os.O_WRONLY|os.O_CREATE|os.O_APPEND, 0755)
defer fileWriter.Close()
if err != nil {
log.Fatalln("Can't open log.txt...", err)
}
logger := log.New(io.Writer(fileWriter), "", log.Lshortfile|log.Ldate|log.LstdFlags)
// 每60s探测一次
go func() {
for t := range ticker.C {
fmt.Println("Tick at", t)
// resp, err := http.Get(IDocViewUrl)
resp, err := http.Get(IDocViewUrl)
if err != nil {
log.Println(err)
log.Println(pidSlice)
log.Printf("正在进行第【%v/3】次探测。。。\n", len(pidSlice))
HandleReturnResp(strings.NewReader(""), 0, logger)
continue
}
HandleReturnResp(resp.Body, resp.StatusCode, logger)
}
ch <- 1
}()
<-ch
}
// HandleReturnResp: 处理body返回内容以及返回响应码
func HandleReturnResp(r io.Reader, respCode int, logger *log.Logger) {
if len(pidSlice) >= 3 {
pidSlice = nil
}
body, err := ioutil.ReadAll(r)
if err != nil {
logger.Println(err)
}
respStr := string(body)
matchStr, _ := regexp.MatchString(".*10.6.1_20200807.*", respStr)
// 满足正则表达要求，且返回值为200
if respCode == 0 {
// *** 存活性探测失败：0
pidSlice = append(pidSlice, 0)
GetPorcessPid(logger)
} else if matchStr && respCode == 200 {
// *** 通过存活性探测，且通过就绪性探测: 1
pidSlice = append(pidSlice, 1)
logger.SetPrefix("【SUCCESS】")
logger.Println("服务正常，状态码", respCode, "\r\n")
logrus.Info("服务正常!")
} else {
// *** 通过存活性探测，但就绪性探测失败：0
pidSlice = append(pidSlice, 0)
GetPorcessPid(logger)
}
}
// GetPorcessPid: 重启iDocView服务
func GetPorcessPid(logger *log.Logger) {
cmd := exec.Command("tasklist.exe", "/fo", "csv", "/nh")
out, err := cmd.Output()
if err != nil {
log.Println(err)
}
// 使用正则匹配iiDocView运行之后的Java进程
re := regexp.MustCompile(".*java.*")
text := strings.Join(re.FindAllString(string(out), -1), ",")
pid := strings.Split(text, ",")
// if len(pidSlice) >= 3 {
// pidSlice = nil
// }
logger.SetPrefix("【FAILED】 ")
logger.Printf("探活失败--%v--\r\n", len(pidSlice))
// 当进程不存在时，会抛出超索引panic，在此使用recover进行捕获
// 标志0为进程不存在
defer func() {
if err := recover(); err != nil {
// pidSlice = append(pidSlice, 0)
HandleProcessCondition(pidSlice, "")
}
}()
fmt.Println("the Java process pid is: ", pid[1])
// 标志1为进程存在
// pidSlice = append(pidSlice, 1)
HandleProcessCondition(pidSlice, pid[1])
}
// 当满足条件时杀死该进程，一分钟内探活三次，
// 三次有两次失败则杀死进程，然后尝试重启进程.
func HandleProcessCondition(signal []int, pid string) {
logrus.Warn(signal)
if len(signal) == 3 {
log.Printf("正在进行第【%v/3】次探测。。。\r\n", len(signal))
Sum = signal[0] + signal[1] + signal[2]
if Sum >= 2 {
logrus.Info("iDocView存活")
} else {
ticker.Stop()
// signal = nil
log.Printf("iDocView挂了，即将进行重启...【%v】\r\n", pid)
HandleProcess(pid)
ticker.Reset(interval)
}
} else {
log.Printf("正在进行第【%v/3】次探测。。。\r\n", len(signal))
}
}
// 没有通过存活检验的pid将会传到这里
// 根据pid，杀死进程，然后重新启动该进程
func HandleProcess(pid string) {
if pid != "" {
killCMD := exec.Command("taskkill.exe", "/F", "/im", "java.exe", "/T")
output, err := killCMD.Output()
if err != nil {
log.Println(err)
}
logrus.Error("Killing iDocView Process: ", output)
}
time.Sleep(time.Second * 1)
// 重新启动程序，执行启动命令
log.Println("正在启动服务。。")
startCMD := exec.Command("cmd.exe", "/C", "start", "D:\\idocv\\start.bat")
startCMD.Start()
time.Sleep(time.Second * 2)
log.Println("启动成功，数秒后将打开测试页面。。。")
time.Sleep(time.Second * 12)
openURLCMD := exec.Command("rundll32", "url.dll,FileProtocolHandler", IDocViewUrl)
openURLCMD.Start()
}
// Log2fileAndStdout: 同时将标准输出到终端和日志文件中.
// 保留，暂不启用
func Log2fileAndS1tdout(f *os.File, logText string) {
// 设置日志输出到文件
// 定义多个写入器
writers := []io.Writer{
f,
os.Stdout}
fileAndStdoutWriter := io.MultiWriter(writers...)
// 创建新的log对象
logger := log.New(fileAndStdoutWriter, "", log.Ldate|log.Ltime|log.Lshortfile)
// 使用新的log对象，写入日志内容
logger.Println(logText)
}
|
