由于歷史原因,幾個項目都選用hessian作為web service的實現方式,hessian的確是非常輕量級,基于http協議進行傳輸,通過自定義的串行化機制將請求信息進行序列化,以二進制傳輸節省了不少的開銷,速度跟socket差不多.客戶端和服務器發起和接收請求都是通過spring提供的hessian api進行請求和接收,但是在服務端中并沒有記錄和控制遠端ip地址和主機的信息,所以需要對源碼進行一些重寫
對org.springframework.remoting.caucho.HessianServiceExporter進行重寫
/**
* 重寫HessianServiceExporter.handleRequest(),攔截獲取遠端調用信息
* @author chenyz
*
*/
public class HouseHessianServiceExporter extends HessianServiceExporter {
private static String[] entryIP = {"192.168.0.1","192.168.0.3","192.168.0.3"};
private static Log log = LogFactory.getLog("Myremote");
@Override
public void handleRequest(HttpServletRequest request,
HttpServletResponse response) throws ServletException, IOException {
log.info("try ==>remote 's IP:"+IpUtil.getIpAddr(request)+"remote 's host: "+request.getRemoteHost());
int call = 0;
for(String ip:entryIP){
if(ip.equals(IpUtil.getIpAddr(request)))
call++;
}
if(call>0){
log.info("call ==>remote 's IP:"+IpUtil.getIpAddr(request)+"remote 's host: "+request.getRemoteHost());
super.handleRequest(request, response);
}
}
}
<bean id="shineLibWSImpl" class="com.***.shine.remote.ShineLibWSImpl"/>
<bean name="/remote/shineinfo" class="com.***.shine.hessian.service.HouseHessianServiceExporter">
<property name="service">
<ref bean="shineLibWSImpl"/>
</property>
<property name="serviceInterface">
<value>com.***.shine.remote.ShineLibWebService</value>
</property>
</bean>
重寫HessianServiceExporter.handleRequest(),攔截獲取遠端調用信息,提取出調用端的ip信息與服務端制定的ip列表進行對比,并將所有調用信息記錄日志
如果直接使用hessian的api的HessianServlet,直接對HessianServlet的service()重寫,攔截并提取遠端調用信息
/**
* 重寫HouseHessianServlet.service(),攔截獲取遠端調用信息
* @author chenyz
*
*/
public class HouseHessianServlet extends HessianServlet{
private static String[] entryIP = {"192.168.0.1","192.168.0.3","192.168.0.3"};
private static Log log = LogFactory.getLog("Myremote");
@Override
public void service(ServletRequest request, ServletResponse response)
throws IOException, ServletException {
HttpServletRequest req = (HttpServletRequest) request;
log.info("try ==>remote 's IP:"+IpUtil.getIpAddr(req)+"remote 's host: "+request.getRemoteHost());
int call = 0;
for(String ip:entryIP){
if(ip.equals(IpUtil.getIpAddr(request)))
call++;
}
if(call>0){
log.info("call ==>remote 's IP:"+IpUtil.getIpAddr(req)+"remote 's host: "+request.getRemoteHost());
super.service(request, response);
}
}
}
web.xml
<servlet>
<servlet-name>HessianServlet</servlet-name>
<servlet-class>
com.***.product.remote.Htest
</servlet-class>
</servlet>
<servlet-mapping>
<servlet-name>HessianServlet</servlet-name>
<url-pattern>/service/hession</url-pattern>
</servlet-mapping>
com.***.product.remote.Htest
public class Htest extends HouseHessianServlet implements IHtest{
public hello(){
System.out.println("hello");
}
}