java 对 URL访问、校验端口是否占用、IP是否ping通

package cn.microvideo.info.service.impl;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.InetAddress;
import java.net.InetSocketAddress;
import java.net.Socket;
import java.net.SocketAddress;
import java.net.URL;
import java.net.URLConnection;
import java.util.List;
import java.util.regex.Matcher;
import java.util.regex.Pattern;

import javax.xml.parsers.ParserConfigurationException;
import javax.xml.transform.TransformerException;
import javax.xml.xpath.XPathExpressionException;

import org.apache.commons.lang.StringUtils;
import org.apache.log4j.Logger;
import org.springframework.stereotype.Service;
import org.xml.sax.SAXException;

import cn.microvideo.info.domain.ServiceMonitorInfo;
import cn.microvideo.info.service.MonitorService;
import cn.microvideo.info.util.ServiceXMLUtil;

@Service("monitorService")
public class MonitorServiceImpl implements MonitorService {

private Logger log = Logger.getLogger(MonitorServiceImpl.class);

@Override
public void execute() {
ServiceXMLUtil serviceUtil = ServiceXMLUtil.getInstance();
List<ServiceMonitorInfo> services = serviceUtil.getServices();
for (ServiceMonitorInfo service : services) {
monitoring(service);
}
}

private void monitoring(ServiceMonitorInfo service) {
String state = "监控服务获取失败";
if (service != null) {
boolean servResult = false;
String url = service.getUrl();
if (StringUtils.isNotBlank(url)) {
String result = null;
if ("post".equalsIgnoreCase(service.getMethod())) {
try {
result = postSend(url, service.getParam());
} catch (Exception e) {
}
if (StringUtils.isNotBlank(result)) {
servResult = true;
}
} else if ("get".equalsIgnoreCase(service.getMethod())) {
try {
result = sendGet(url, service.getParam());
} catch (Exception e) {
}
if (StringUtils.isNotBlank(result)) {
servResult = true;
}
}
if (!servResult) {
String regex = "//(.*?):(\\d+)/";
Pattern p = Pattern.compile(regex);
Matcher m = p.matcher(url);
while (m.find()) {
String location = m.group(1);
try {
Integer port = Integer.parseInt(m.group(2));
servResult = validePort(location, port);
} catch (Exception e) {
servResult = false;
}
if (!servResult) {
try {
servResult = ping(location);
} catch (Exception e) {
servResult = false;
}
if(servResult){
state = "服务器【IP】能够正常访问";
}
}else{
state = "服务器【端口】能够正常访问";
}

}
}else{
state = "服务器【地址】能够正常访问";
}
if(!servResult){
state = "服务器【地址、端口、IP】都无法访问";
}
}
}
service.setState(state);
ServiceXMLUtil serviceUtil = ServiceXMLUtil.getInstance();
try {
serviceUtil.updateNodeById(service);
} catch (XPathExpressionException e) {
e.printStackTrace();
} catch (TransformerException e) {
e.printStackTrace();
} catch (ParserConfigurationException e) {
e.printStackTrace();
} catch (SAXException e) {
e.printStackTrace();
} catch (IOException e) {
e.printStackTrace();
}
}

private String postSend(String url, String param) {
String result = null;
PrintWriter out = null;
BufferedReader in = null;
try {
URL realUrl = new URL(url);
URLConnection conn = realUrl.openConnection();
conn.setRequestProperty("accept", "*/*");
conn.setRequestProperty("connection", "Keep-Alive");
conn.setRequestProperty("user-agent", "Mozilla/4.0 (compatible;MSIE 6.0;Windows NT 5.1;SV1)");
conn.setDoOutput(true);
out = new PrintWriter(conn.getOutputStream());
out.print(param);
out.flush();
in = new BufferedReader(new InputStreamReader(conn.getInputStream()));
String line;
while ((line = in.readLine()) != null) {
result += line;
}
} catch (Exception e) {
log.error("服务监控，发送POST请求异常:"+e.getMessage());
} finally {
try {
if (out != null)
out.close();
} catch (Exception e2) {
}
try {
if (in != null)
in.close();
} catch (Exception e2) {
}
}

return result;
}

private String sendGet(String url, String param) {
String result = "";
BufferedReader in = null;
try {
String urlNameString = url + "?" + param;
URL realUrl = new URL(urlNameString);
URLConnection connection = realUrl.openConnection();
connection.setRequestProperty("accept", "text/html, application/xhtml+xml, */*");
connection.setRequestProperty("connection", "Keep-Alive");
connection.setRequestProperty("Accept-Encoding", "gzip, deflate");
connection.setRequestProperty("Accept-Language", "zh-CN");
connection.setRequestProperty("user-agent", "Mozilla/5.0 (compatible; MSIE 9.0; Windows NT 6.1; WOW64; Trident/5.0)");
connection.connect();
in = new BufferedReader(new InputStreamReader(connection.getInputStream()));
String line;
while ((line = in.readLine()) != null) {
result += line;
}
} catch (Exception e) {
log.error("服务监控，发送GET请求异常:"+e.getMessage());
} finally {
try {
if (in != null) {
in.close();
}
} catch (Exception e2) {
}
}
return result;
}

/** 当返回值是true时，说明host是可用的，false则不可。*/
public static boolean ping(String ipAddress) throws Exception {
int timeOut = 3000; // 超时应该在3钞以上
boolean status = InetAddress.getByName(ipAddress).isReachable(timeOut);
return status;
}

private boolean validePort(String location, int port) {
Socket s = new Socket();
try {
SocketAddress add = new InetSocketAddress(location, port);
s.connect(add, 2000);
return true;
} catch (IOException e) {
return false;
}finally{
try {
s.close();
} catch (IOException e1) {
}
}
}

}