<bean id="httpInvokerUserService" class="org.springframework.remoting.httpinvoker.HttpInvokerProxyFactoryBean">  <property name="serviceUrl" value="http://localhost:8080/jws/httpInvokerUserService.service"/>  <property name="serviceInterface" value="com.gosun.jws.httpinvoker.UserService" />
</bean> 

public class HttpInvokerProxyFactoryBean extends HttpInvokerClientInterceptor  implements FactoryBean  

public void afterPropertiesSet()
{  super.afterPropertiesSet();  if(getServiceInterface() == null)  {  throw new IllegalArgumentException("Property 'serviceInterface' is required");  } else  {  //创建代理并使用当前方法为拦截器增强  serviceProxy = (new ProxyFactory(getServiceInterface(), this)).getProxy(getBeanClassLoader());  return;  }
}  

public Object getObject(){  return serviceProxy;
}  

ApplicationContext ac = new ClassPathXmlApplicationContext("client-application/applicationContext-httpInvoker.xml");
UserService us = (UserService) ac.getBean("httpInvokerUserService");
Users user = us.getUser("a001");  

    public Object invoke(MethodInvocation methodInvocation) throws Throwable  {  if(AopUtils.isToStringMethod(methodInvocation.getMethod()))  return (new StringBuilder())　　　　　　　　　　.append("HTTP invoker proxy for service URL [")　　　　　　　　　　.append(getServiceUrl())　　　　　　　　　　.append("]").toString();  //将要调用的方法封装RemoteInvocation  RemoteInvocation invocation = createRemoteInvocation(methodInvocation);  RemoteInvocationResult result = null;  try  {  result = executeRequest(invocation, methodInvocation);  }  catch(Throwable ex)  {  throw convertHttpInvokerAccessException(ex);  }  try  {  return recreateRemoteInvocationResult(result);  }  catch(Throwable ex)  {  if(result.hasInvocationTargetException())  throw ex;  else  throw new RemoteInvocationFailureException((new StringBuilder())　　　　　　　　　　　　.append("Invocation of method [")　　　　　　　　　　　　.append(methodInvocation.getMethod())　　　　　　　　　　　　.append("] failed in HTTP invoker remote service at [")　　　　　　　　　　　　.append(getServiceUrl()).append("]").toString(), ex);  }  }  

protected RemoteInvocationResult executeRequest(RemoteInvocation invocation, MethodInvocation originalInvocation)  throws Exception
{  return executeRequest(invocation);
}
protected RemoteInvocationResult executeRequest(RemoteInvocation invocation)  throws Exception
{  return getHttpInvokerRequestExecutor().executeRequest(this, invocation);
}
public final RemoteInvocationResult executeRequest(HttpInvokerClientConfiguration config, RemoteInvocation invocation)  throws Exception
{  //获取输出流  ByteArrayOutputStream baos = getByteArrayOutputStream(invocation);  if(logger.isDebugEnabled())  logger.debug((new StringBuilder())　　　　　　　　.append("Sending HTTP invoker request for service at [")　　　　　　　　.append(config.getServiceUrl()).append("], with size ")　　　　　　　　.append(baos.size()).toString());  return doExecuteRequest(config, baos);
}  

protected RemoteInvocationResult doExecuteRequest(HttpInvokerClientConfiguration config, ByteArrayOutputStream baos)  throws IOException, ClassNotFoundException  {  //创建httpPost  PostMethod postMethod = createPostMethod(config);  RemoteInvocationResult remoteinvocationresult;  //设置含有方法的输出流到post中
       setRequestBody(config, postMethod, baos);  //执行方法
       executePostMethod(config, getHttpClient(), postMethod);  //验证
       validateResponse(config, postMethod);  //提取返回的输入流  InputStream responseBody = getResponseBody(config, postMethod);  //从输入流中提取结果  remoteinvocationresult = readRemoteInvocationResult(responseBody, config.getCodebaseUrl());  postMethod.releaseConnection();  return remoteinvocationresult;  }  

protected PostMethod createPostMethod(HttpInvokerClientConfiguration config)  throws IOException
{  //设置需要访问的url  PostMethod postMethod = new PostMethod(config.getServiceUrl());  LocaleContext locale = LocaleContextHolder.getLocaleContext();  if(locale != null)  //加入Accept-Language属性  postMethod.addRequestHeader("Accept-Language", StringUtils.toLanguageTag(locale.getLocale()));  if(isAcceptGzipEncoding())  //加入Accept-Encoding属性  postMethod.addRequestHeader("Accept-Encoding", "gzip");  return postMethod;
}  

protected void setRequestBody(HttpInvokerClientConfiguration config, PostMethod postMethod, ByteArrayOutputStream baos)  throws IOException
{  //将序列化流加入到postMethod中并声明ContentType类型为appliction、x-java-serialized-object  postMethod.setRequestEntity(new ByteArrayRequestEntity(baos.toByteArray(), getContentType()));
}  

protected void executePostMethod(HttpInvokerClientConfiguration config, HttpClient httpClient, PostMethod postMethod)  throws IOException
{  httpClient.executeMethod(postMethod);
}  

protected void validateResponse(HttpInvokerClientConfiguration config, PostMethod postMethod)  throws IOException
{  if(postMethod.getStatusCode() >= 300)  throw new HttpException((new StringBuilder())　　　　　　　　.append("Did not receive successful HTTP response: status code = ")　　　　　　　　.append(postMethod.getStatusCode())　　　　　　　　.append(", status message = [")　　　　　　　　.append(postMethod.getStatusText())　　　　　　　　.append("]").toString());  else  return;
}  

protected InputStream getResponseBody(HttpInvokerClientConfiguration config, PostMethod postMethod)  throws IOException
{  if(isGzipResponse(postMethod))  return new GZIPInputStream(postMethod.getResponseBodyAsStream());  else  return postMethod.getResponseBodyAsStream();
}  

    protected RemoteInvocationResult readRemoteInvocationResult(InputStream is, String codebaseUrl)throws IOException, ClassNotFoundException {ObjectInputStream ois = createObjectInputStream(decorateInputStream(is), codebaseUrl);try {return doReadRemoteInvocationResult(ois);}finally {ois.close();}}protected RemoteInvocationResult doReadRemoteInvocationResult(ObjectInputStream ois)throws IOException, ClassNotFoundException {Object obj = ois.readObject();if (!(obj instanceof RemoteInvocationResult)) {throw new RemoteException("Deserialized object needs to be assignable to type [" +RemoteInvocationResult.class.getName() + "]: " + obj);}return (RemoteInvocationResult) obj;}