Jax-ws:在数据库中记录请求和响应
Jax-ws: Log request and response in database
我有一个包含 getEmployeeList 方法的 Web 服务,我需要在数据库中记录请求和响应,例如;
***Column** **Id Request Response ResponseTime***
1 Request1 Response1 600ms
2 Request2 Response2 400ms
我的员工服务class;
@WebService
@HandlerChain(file="employeehandler-chain.xml")
public interface EmployeeWS {
@WebMethod
List<Employee> getEmployeeList(
@WebParam(name = " EmployeeReq") EmployeeReq employeeReq);
我的自定义处理程序 class ;
public class EmployeeHandler implements SOAPHandler<SOAPMessageContext> {
@Override
public boolean handleMessage(SOAPMessageContext context) {
Boolean outBound = (Boolean) context.get(MessageContext.MESSAGE_OUTBOUND_PROPERTY);
try {
SOAPMessage soapMsg = context.getMessage();
有没有办法在我的处理程序中关联请求和响应?
您可以在处理入站消息时创建一个 ID 并保存到 SOAPMessageContext
并在处理响应时获取它:
Boolean outBound = (Boolean) context.get(MessageContext.MESSAGE_OUTBOUND_PROPERTY);
if (!outbound) {
Long messageId = createId();
context.put("messageId", messageId);
saveRequestToDatabase(context.getMessage(), messageId);
} else {
saveResponseToDatabase(context.getMessage(), context.get("messageId"));
}
每个请求都会创建一个新的SOAPMessageContext
,它一直保持活动状态直到响应过程结束,因此即使同时执行各种请求,每个上下文也会不同。
我有一个包含 getEmployeeList 方法的 Web 服务,我需要在数据库中记录请求和响应,例如;
***Column** **Id Request Response ResponseTime***
1 Request1 Response1 600ms
2 Request2 Response2 400ms
我的员工服务class;
@WebService
@HandlerChain(file="employeehandler-chain.xml")
public interface EmployeeWS {
@WebMethod
List<Employee> getEmployeeList(
@WebParam(name = " EmployeeReq") EmployeeReq employeeReq);
我的自定义处理程序 class ;
public class EmployeeHandler implements SOAPHandler<SOAPMessageContext> {
@Override
public boolean handleMessage(SOAPMessageContext context) {
Boolean outBound = (Boolean) context.get(MessageContext.MESSAGE_OUTBOUND_PROPERTY);
try {
SOAPMessage soapMsg = context.getMessage();
有没有办法在我的处理程序中关联请求和响应?
您可以在处理入站消息时创建一个 ID 并保存到 SOAPMessageContext
并在处理响应时获取它:
Boolean outBound = (Boolean) context.get(MessageContext.MESSAGE_OUTBOUND_PROPERTY);
if (!outbound) {
Long messageId = createId();
context.put("messageId", messageId);
saveRequestToDatabase(context.getMessage(), messageId);
} else {
saveResponseToDatabase(context.getMessage(), context.get("messageId"));
}
每个请求都会创建一个新的SOAPMessageContext
,它一直保持活动状态直到响应过程结束,因此即使同时执行各种请求,每个上下文也会不同。