httpinvoke客户端代码实现
2017-04-06 15:47
204 查看
package com.csair.soc.aircrew.rostereditor.httpinvoke;
import java.io.IOException;
import java.io.InputStream;
import java.util.Properties;
import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.ConcurrentMap;
import org.springframework.remoting.httpinvoker.HttpInvokerProxyFactoryBean;
import com.csair.soc.aircrew.rulecheck.rmi.RuleCheckService;
/**
* 远程调用工具类
*
* @author Johnson
* @version Saturday March 2nd, 2013
*/
public class HttpInvokeFactory {
private static String URL = "http://10.95.18.88:8080/aircrew-rulecheck-biz";
private static ConcurrentMap<String, Object> serviceProxyMap = new ConcurrentHashMap<String, Object>();
private static ConcurrentMap<Class<?>, String> serviceUrlMap = new ConcurrentHashMap<Class<?>, String>();
/**
* 注册默认服务地址
*/
static {
Properties properties = new Properties();
// jndi配置文件路径
String filePath = "META-INF/prop/httpinvoke.properties";
InputStream in = HttpInvokeFactory.class.getClassLoader().getResourceAsStream(filePath);
try {
properties.load(in);
} catch (IOException e) {
e.printStackTrace();
}
URL = properties.getProperty("httpinvoke.url");
serviceUrlMap.put(RuleCheckService.class, URL + "/RuleCheckHttpInvokerService");
}
/**
* 创建服务对象
*
* @param <T>
* @param serviceUrl
* @param clazz
* @return
*/
@SuppressWarnings("unchecked")
private static <T> T createService(String serviceUrl, Class<T> clazz) {
HttpInvokerProxyFactoryBean bean = new HttpInvokerProxyFactoryBean();
bean.setServiceUrl(serviceUrl);
bean.setServiceInterface(clazz);
bean.afterPropertiesSet();
return (T) bean.getObject();
}
/**
* 添加服务地址
*
* @param clazz
* @param serviceUrl
*/
public static void put(Class<?> clazz, String serviceUrl) {
if (serviceUrlMap.containsKey(clazz)) {
return;
}
serviceUrlMap.put(clazz, serviceUrl);
}
/**
* 获取服务对象
*
* @param <T>
* @param clazz
* @return
*/
@SuppressWarnings("unchecked")
public static <T> T getService(Class<T> clazz) {
String serviceUrl = serviceUrlMap.get(clazz);
if (serviceUrl == null) {
return null;
}
Object service = serviceProxyMap.get(serviceUrl);
if (service == null) {
service = HttpInvokeFactory.createService(serviceUrl, clazz);
serviceProxyMap.put(serviceUrl, service);
}
return (T) service;
}
}
import java.io.IOException;
import java.io.InputStream;
import java.util.Properties;
import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.ConcurrentMap;
import org.springframework.remoting.httpinvoker.HttpInvokerProxyFactoryBean;
import com.csair.soc.aircrew.rulecheck.rmi.RuleCheckService;
/**
* 远程调用工具类
*
* @author Johnson
* @version Saturday March 2nd, 2013
*/
public class HttpInvokeFactory {
private static String URL = "http://10.95.18.88:8080/aircrew-rulecheck-biz";
private static ConcurrentMap<String, Object> serviceProxyMap = new ConcurrentHashMap<String, Object>();
private static ConcurrentMap<Class<?>, String> serviceUrlMap = new ConcurrentHashMap<Class<?>, String>();
/**
* 注册默认服务地址
*/
static {
Properties properties = new Properties();
// jndi配置文件路径
String filePath = "META-INF/prop/httpinvoke.properties";
InputStream in = HttpInvokeFactory.class.getClassLoader().getResourceAsStream(filePath);
try {
properties.load(in);
} catch (IOException e) {
e.printStackTrace();
}
URL = properties.getProperty("httpinvoke.url");
serviceUrlMap.put(RuleCheckService.class, URL + "/RuleCheckHttpInvokerService");
}
/**
* 创建服务对象
*
* @param <T>
* @param serviceUrl
* @param clazz
* @return
*/
@SuppressWarnings("unchecked")
private static <T> T createService(String serviceUrl, Class<T> clazz) {
HttpInvokerProxyFactoryBean bean = new HttpInvokerProxyFactoryBean();
bean.setServiceUrl(serviceUrl);
bean.setServiceInterface(clazz);
bean.afterPropertiesSet();
return (T) bean.getObject();
}
/**
* 添加服务地址
*
* @param clazz
* @param serviceUrl
*/
public static void put(Class<?> clazz, String serviceUrl) {
if (serviceUrlMap.containsKey(clazz)) {
return;
}
serviceUrlMap.put(clazz, serviceUrl);
}
/**
* 获取服务对象
*
* @param <T>
* @param clazz
* @return
*/
@SuppressWarnings("unchecked")
public static <T> T getService(Class<T> clazz) {
String serviceUrl = serviceUrlMap.get(clazz);
if (serviceUrl == null) {
return null;
}
Object service = serviceProxyMap.get(serviceUrl);
if (service == null) {
service = HttpInvokeFactory.createService(serviceUrl, clazz);
serviceProxyMap.put(serviceUrl, service);
}
return (T) service;
}
}
相关文章推荐
- Spring HttpInvoke 客户端调用代码实现
- nodejs 原生代码实现http 服务器和客户端并交互
- C++实现搜狗浏览器加速代理客户端(HTTP/HTTPS)的核心代码
- .Net/C#: 实现支持断点续传多线程下载的 Http Web 客户端工具类
- Net/C#: 实现支持断点续传多线程下载的 Http Web 客户端工具类 (转,尚未整理)
- [收藏]实现支持断点续传多线程下载的 Http Web 客户端工具类 (第2版)
- HttpModule 实现 ASP.Net (*.aspx) 中文简繁体的自动转换,不用修改原有的任何代码,直接部署即可!
- .Net/C#: 实现支持断点续传多线程下载的 Http Web 客户端工具类 (第2版) (C# DIY HttpWebClient)
- ASP.NET 2.0 HttpHandler实现生成图片验证码(示例代码下载)
- /* .Net/C#: 实现支持断点续传多线程下载的 Http Web 客户端工具类【转】
- .Net/C#: 实现支持断点续传多线程下载的 Http Web 客户端工具类 (第2版) (C# DIY HttpWebClient) 收藏
- JS实现的客户端使用的播放器代码
- Windows NT/2000/XP下不用驱动的Ring0代码实现(http://webcrazy.yeah.net)
- ASP.NET 2.0 HttpHandler实现生成图片验证码(示例代码下载)
- ASP.NET 2.0 HttpHandler实现生成图片验证码(示例代码下载)
- ASP.NET 2.0 HttpHandler实现对某种文件类型权限保护(示例代码下载)
- .Net/C#: 实现支持断点续传多线程下载的 Http Web 客户端工具类 (C# DIY HttpWebClient)
- .Net/C#: 实现支持断点续传多线程下载的 Http Web 客户端工具类 (C# DIY HttpWebClient)
- Net/C#: 实现支持断点续传多线程下载的 Http Web 客户端工具类 (C# DIY HttpWebClient)
- ASP.NET 2.0 HttpHandler实现对某种文件类型权限保护(示例代码下载)