EB项目总结

在容器启动时(实现ServletContextListener接口)，使用Session bean将SysConfig表和IP权限表数据读出并放入缓存中

 

下一步，两种方式：

1、通过在JBOSS中配置全局过滤器，过滤IP权限和访问开关，然后通过JMS发出输入、输出

request发出后，经过SOAPHandler拦截器、EJB拦截器，然后返回response

 

注意：

1、过滤器通过后，需要将ThreadLocal里的UUID置空，保证下一请求从新获取UUID

 

2、使用ThreadLocal保证该过程在同一线程中，输入输出的UUID都从ThreadLocal里拿，保证一一对应。

 

3、EJB过滤器里调用前设入开始时间，调用后设入结束时间（ThreadLocal设置，然后构造输出对象时置入，方便获知调用时长）

 

4、发送的request构造RequestData对象，置入requestSoap(String类型),UUID、IP、URI、serviceNameEn、date等，然后通过JMS发出

返回的response构造ResponseData对象，从ThreadLocal里拿到UUID(保证与RequestData对应) , 置入UUID、调用开始结束时间，responseSoap，然后通过JMS发出

 

5、接收到消息后，判断消息类型(RequestData/ResponseData对象)，分别持久化到DB

 

6、分别在request/response请求关闭前，通过下面的InstanceSender构造输入输出对象发送JMS输入输出消息

 

注意点1和2实现：

public class InstanceInfo {
	private static final ThreadLocal instanceUUID = new ThreadLocal();
	
	public static String getInstanceUUID(){
		String uuid = (String)instanceUUID.get();
		if(uuid == null){
			// 生成UUID作为服务调用的实例号
			uuid = PREFIX + UUID.randomUUID().toString().replaceAll("-", "").toUpperCase();
			instanceUUID.set(uuid);
		}
		return uuid;
	}

	public static void removeInstanceUUID(){
		instanceUUID.remove();
		instanceUUID.set(null);
	}
}

 

请求通过后，UUID清空

chain.doFilter(req, res);
	InstanceInfo.removeInstanceUUID();

 

 

注意点3实现：

public class InstanceInfo {
	/**
	 * 调用原始服务开始时间
	 */
	private static final ThreadLocal invokeProviderStartTime = new ThreadLocal();
	
	/**
	 * 调用原始服务结束时间
	 */
	private static final ThreadLocal invokeProviderEndTime = new ThreadLocal();
	
	public static Long getInvokeProviderStartTime(){
		return (Long)invokeProviderStartTime.get();
	}
	
	@SuppressWarnings("unchecked")
	public static void markInvokeProviderStartTime(){
		invokeProviderStartTime.set(System.currentTimeMillis());
	}
	..
}

 

EJB过滤器中，置入调用开始、结束时间：

/**
 * 该类基于EJB拦截器实现
 */
public class InstanceHandler {
	
	@AroundInvoke
	public Object handle(InvocationContext ctx) throws Exception{
		Object obj = null;
		
		// 记录调用原始服务所耗费的时间
		// 起始
		if(InstanceInfo.filterIsUp){
			InstanceInfo.markInvokeProviderStartTime();
		}
		try {
			// 调用服务
			obj = ctx.proceed();
		} catch (Exception e) {			
		}finally{
			// 结束
			if(InstanceInfo.filterIsUp){
				InstanceInfo.markInvokeProviderEndTime();				
			}
			
			if(obj != null){
				ReflectUtil.setValueToField(obj, "instanceid", InstanceInfo.getInstanceUUID());
			}
			
			if(!InstanceInfo.filterIsUp){
				InstanceInfo.removeInstanceUUID();
			}
		}
		return obj;
	}

}

 

 

注意点4实现：

过滤器中：

// 封装请求对象
		RequestData rd = InstanceInfo.getRequestData();
		rd.setInstanceUUID(uuid);
		rd.setDate(new Date(System.currentTimeMillis()));
		rd.setServiceNameEn(serviceNameEn);
		rd.setRequestURI(requestURI);
		rd.setIp(ip);

 

JMS发送输入消息(将请求构造为RequestData对象,方便JMS接收端接收)：

public class InstanceSender {
	
	/**
	 * 将soap消息封装后发送至jms(输入消息)
	 */
	public static void sendInput(byte[] byteContent){
		// 封装requestData
		//过滤器中设置过值的requestData
		RequestData rd = InstanceInfo.getRequestData();  		
		
		//转码
		String encoding = InstanceInfo.getInputStreamEncoding();
		String soap = null;		
		if(byteContent.length > 0){
			if(encoding != null){
				try {
					soap = new String(byteContent, encoding);
				} catch (UnsupportedEncodingException e) {				
				}
			}else{
				soap = new String(byteContent);
			}
		}
		
		rd.setSoap(soap);
		
		// 发送输入消息
		try {
			MsgQueueSender.getInstance().sendObjMsg(rd);
		} catch (JMSException e) {			
		}
		
		// 释放请求数据占用内存
		InstanceInfo.removeRequestData();
	}
	
}

 

JMS发送输出消息(将请求构造为ResponseData对象,方便JMS接收端接收)：：

public class InstanceSender {
	
	/**	
	 * 将soap消息封装后发送至jms(输出消息)		
	 */
	public static void sendOutput(byte[] byteContent, StringBuffer strContent){
		// 封装响应对象
		ResponseData rd = InstanceInfo.getResponseData();
		rd.setInstanceUUID(InstanceInfo.getInstanceUUID());
		rd.setDate(new Date(System.currentTimeMillis()));
		
		String soap = null;		
		if(byteContent.length > 0){
			String encoding = InstanceInfo.getOutputStreamEncoding();
			if(encoding != null){
				try {
					soap = new String(byteContent, encoding);
				} catch (UnsupportedEncodingException e) {					
				}
			}else{
				soap = new String(byteContent);
			}
		}else if(strContent.length() > 0){
			soap = strContent.toString();
		}
		
		rd.setSoap(soap);
		
		//此处拿出EJB过滤器中，置入的调用开始、结束时间		
		if(InstanceInfo.getInvokeProviderStartTime() != null){
			rd.setOriginalRequestTime(InstanceInfo.getInvokeProviderStartTime());
		}				
		if(InstanceInfo.getInvokeProviderEndTime() != null){
			rd.setOriginalResponseTime(InstanceInfo.getInvokeProviderEndTime());
		}
		
		// 发送输出消息
		try {
			MsgQueueSender.getInstance().sendObjMsg(rd);
		} catch (JMSException e) {			
		}
		
		// 释放响应数据占用内存
		InstanceInfo.removeResponseData();
	}
	
}

 

public class InstanceInfo {
	/**
	 * 请求数据
	 */
	private static final ThreadLocal requestData = new ThreadLocal();
	
	/**
	 * 响应数据
	 */
	private static final ThreadLocal responseData = new ThreadLocal();

	public static RequestData getRequestData(){
		RequestData rd = (RequestData)requestData.get();
		if(rd == null){
			rd = new RequestData();
			requestData.set(rd);
		}
		return rd;
	}
	
	public static void removeRequestData(){
		requestData.remove();
		// 此前出现多个请求实例号重复的情况，推测是jboss重复使用线程，所以此处保留setnull代码
		requestData.set(null);
	}
	
	//ResponseData类似，忽略
	..
}

 

 

注意点6实现：

Filter中，HttpServletRequestWrapper/HttpServletResponseWrapper包装HttpServletRequest/HttpServletResponse对象

 

request关闭前，JMS发送输入：

@Override
	public void close() throws IOException {
		if(!closed){
			InstanceSender.sendInput(byteContent);
		}
		sis.close(); 
		closed = true;
	}

 

response关闭前，JMS发送输出

@Override
	public void close() throws IOException {
		if(!closed){
			InstanceSender.sendOutput(byteContent, strContent);
		}
		sos.close();
		closed = true;
	}

 

。。