本文整理汇总了Java中org.springframework.remoting.rmi.RmiProxyFactoryBean类的典型用法代码示例。如果您正苦于以下问题:Java RmiProxyFactoryBean类的具体用法?Java RmiProxyFactoryBean怎么用?Java RmiProxyFactoryBean使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
RmiProxyFactoryBean类属于org.springframework.remoting.rmi包,在下文中一共展示了RmiProxyFactoryBean类的20个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Java代码示例。
示例1: obtain
import org.springframework.remoting.rmi.RmiProxyFactoryBean; //导入依赖的package包/类
/**
* Utility method to lookup a remote stream peer over RMI.
*/
public static RemoteInputStreamServer obtain(String host, int port, String name) throws RemoteException
{
RmiProxyFactoryBean rmiProxyFactoryBean = new RmiProxyFactoryBean();
rmiProxyFactoryBean.setServiceUrl("rmi://" + host + ":" + port + "/" + name);
rmiProxyFactoryBean.setServiceInterface(RemoteInputStreamServer.class);
rmiProxyFactoryBean.setRefreshStubOnConnectFailure(true);
try
{
rmiProxyFactoryBean.afterPropertiesSet();
}
catch (Exception e)
{
throw new RemoteException("Error create rmi proxy");
}
return (RemoteInputStreamServer) rmiProxyFactoryBean.getObject();
}
开发者ID:Alfresco,项目名称:alfresco-repository,代码行数:20,代码来源:RmiRemoteInputStreamServer.java
示例2: doRefer
import org.springframework.remoting.rmi.RmiProxyFactoryBean; //导入依赖的package包/类
@SuppressWarnings("unchecked")
protected <T> T doRefer(final Class<T> serviceType, final URL url) throws RpcException {
final RmiProxyFactoryBean rmiProxyFactoryBean = new RmiProxyFactoryBean();
//RMI传输时使用自定义的远程执行对象,从而传递额外的参数
rmiProxyFactoryBean.setRemoteInvocationFactory(new RemoteInvocationFactory() {
public RemoteInvocation createRemoteInvocation(MethodInvocation methodInvocation) {
return new RmiRemoteInvocation(methodInvocation);
}
});
rmiProxyFactoryBean.setServiceUrl(url.toIdentityString());
rmiProxyFactoryBean.setServiceInterface(serviceType);
rmiProxyFactoryBean.setCacheStub(true);
rmiProxyFactoryBean.setLookupStubOnStartup(true);
rmiProxyFactoryBean.setRefreshStubOnConnectFailure(true);
rmiProxyFactoryBean.afterPropertiesSet();
return (T) rmiProxyFactoryBean.getObject();
}
开发者ID:hufeng,项目名称:dubbo2.js,代码行数:18,代码来源:RmiProtocol.java
示例3: doRefer
import org.springframework.remoting.rmi.RmiProxyFactoryBean; //导入依赖的package包/类
@SuppressWarnings("unchecked")
protected <T> T doRefer(final Class<T> serviceType, final URL url) throws RpcException {
final RmiProxyFactoryBean rmiProxyFactoryBean = new RmiProxyFactoryBean();
rmiProxyFactoryBean.setServiceUrl(url.toIdentityString());
rmiProxyFactoryBean.setServiceInterface(serviceType);
rmiProxyFactoryBean.setCacheStub(true);
rmiProxyFactoryBean.setLookupStubOnStartup(true);
rmiProxyFactoryBean.setRefreshStubOnConnectFailure(true);
rmiProxyFactoryBean.afterPropertiesSet();
return (T) rmiProxyFactoryBean.getObject();
}
开发者ID:dachengxi,项目名称:EatDubbo,代码行数:12,代码来源:RmiProtocol.java
示例4: createConnection
import org.springframework.remoting.rmi.RmiProxyFactoryBean; //导入依赖的package包/类
@Override
public CommunicationConnection createConnection(CommunicationParam params) {
if (params == null) {
throw new IllegalArgumentException("param is null!");
}
// 构造对应的url
String serviceUrl = MessageFormat.format(RMI_SERVICE_URL, params.getIp(), String.valueOf(params.getPort()));
// 自己实现的有连接池的Stub
RmiProxyFactoryBean proxy = new RmiProxyFactoryBean();
proxy.setServiceUrl(serviceUrl);
proxy.setServiceInterface(CommunicationEndpoint.class);
proxy.afterPropertiesSet();
return new RmiCommunicationConnection(params, (CommunicationEndpoint) proxy.getObject());// 创建链接
}
开发者ID:luoyaogui,项目名称:otter-G,代码行数:16,代码来源:RmiCommunicationConnectionFactory.java
示例5: register
import org.springframework.remoting.rmi.RmiProxyFactoryBean; //导入依赖的package包/类
public String register(String workerId, String address) {
RmiProxyFactoryBean factoryBean = new RmiProxyFactoryBean();
factoryBean.setServiceInterface(WorkAPI.class);
factoryBean.setServiceUrl(String.format("rmi://%s:%s/worker", address, workerPort));
factoryBean.afterPropertiesSet();
WorkAPI worker = (WorkAPI) factoryBean.getObject();
String token = UUID.randomUUID().toString();
workers.put(token, worker);
System.out.println(String.format("A worker(%s) at %s registered, and assigned with token(%s)",
workerId, address, token));
return token;
}
开发者ID:Kadvin,项目名称:spring-component-framework,代码行数:13,代码来源:Router.java
示例6: main
import org.springframework.remoting.rmi.RmiProxyFactoryBean; //导入依赖的package包/类
/**
* java -Drouter.port=1097 -Drouter.address=localhost -jar path/to/com.myapp.caller-1.0.0.jar jobId
*
* @param args jobId(mandatory)
*/
public static void main(String[] args) {
if (args.length < 1)
throw new IllegalArgumentException("You must specify a job id");
String jobId = args[0];
RmiProxyFactoryBean factoryBean = new RmiProxyFactoryBean();
factoryBean.setServiceInterface(RouteAPI.class);
factoryBean.setServiceUrl(String.format("rmi://%s:%s/router",
System.getProperty("router.address", "localhost"),
System.getProperty("router.port", "1097")));
factoryBean.afterPropertiesSet();
RouteAPI router = (RouteAPI) factoryBean.getObject();
Object result = router.perform(jobId);
System.out.println("Got router response: " + result);
}
开发者ID:Kadvin,项目名称:spring-component-framework,代码行数:20,代码来源:CLI.java
示例7: start
import org.springframework.remoting.rmi.RmiProxyFactoryBean; //导入依赖的package包/类
@Override
public void start() {
this.running = true;
RmiProxyFactoryBean factoryBean = new RmiProxyFactoryBean();
factoryBean.setServiceInterface(RouteAPI.class);
factoryBean.setServiceUrl(String.format("rmi://localhost:%d/router", routerPort));
factoryBean.afterPropertiesSet();
RouteAPI routeAPI = (RouteAPI) factoryBean.getObject();
routeAPI.register(id, this.ip);
}
开发者ID:Kadvin,项目名称:spring-component-framework,代码行数:11,代码来源:Worker.java
示例8: LauncherThroughPort
import org.springframework.remoting.rmi.RmiProxyFactoryBean; //导入依赖的package包/类
public LauncherThroughPort(String host, int port) {
this.host = host;
this.port = port;
RmiProxyFactoryBean factoryBean = new RmiProxyFactoryBean();
factoryBean.setServiceInterface(Executable.class);
String serviceUrl = String.format("rmi://%s:%d/%sLauncher",
this.host, this.port, System.getProperty("app.name"));
factoryBean.setServiceUrl(serviceUrl);
try {
factoryBean.afterPropertiesSet();
} catch (Exception e) {
throw new IllegalArgumentException("Can't lookup Executable Service at: " + serviceUrl);
}
remote = (Executable) factoryBean.getObject();
}
开发者ID:Kadvin,项目名称:spring-component-framework,代码行数:16,代码来源:LauncherThroughPort.java
示例9: init
import org.springframework.remoting.rmi.RmiProxyFactoryBean; //导入依赖的package包/类
/**
*
*/
@PostConstruct
protected void init() {
try {
log.debug("Trying to reach server at URL : {}", PropertiesConstants.SERVER_URL);
final RmiProxyFactoryBean factory = new RmiProxyFactoryBean();
factory.setServiceInterface(IServer.class);
factory.setServiceUrl(PropertiesConstants.SERVER_URL);
factory.afterPropertiesSet();
server = (IServer) factory.getObject();
} catch (final Exception e) {
// do nothing, let server be null
}
}
开发者ID:djouanno,项目名称:sweetsnake,代码行数:17,代码来源:RmiProvider.java
示例10: importService
import org.springframework.remoting.rmi.RmiProxyFactoryBean; //导入依赖的package包/类
public static <T> T importService(Class<T> serviceInterface, int port, String serviceName, long timeout, TimeUnit timeunit) {
long timeoutMs = timeunit.toMillis(timeout);
String url = "rmi://localhost:" + port + "/" + serviceName;
log.debug("Creating RMI proxy for " + serviceInterface + " on " + url);
RmiProxyFactoryBean rmiFactory = new RmiProxyFactoryBean();
rmiFactory.setServiceInterface(serviceInterface);
rmiFactory.setServiceUrl(url);
rmiFactory.setRefreshStubOnConnectFailure(true);
rmiFactory.setLookupStubOnStartup(true);
boolean connected = false;
RuntimeException thrown = null;
long start = System.currentTimeMillis();
while (!connected && System.currentTimeMillis() - start < timeoutMs) {
try {
rmiFactory.afterPropertiesSet();
connected = true;
} catch (RuntimeException e) {
thrown = e;
try {
Thread.sleep(100);
} catch (InterruptedException e1) {
throw new RuntimeException("Interrupted while waiting for service to be available", e1);
}
}
}
if (!connected) {
throw thrown;
}
T serviceProxy = (T) rmiFactory.getObject();
return serviceProxy;
}
开发者ID:cedricvidal,项目名称:jforkr,代码行数:35,代码来源:RmiUtil.java
示例11: stockService
import org.springframework.remoting.rmi.RmiProxyFactoryBean; //导入依赖的package包/类
@Bean
public RmiProxyFactoryBean stockService() {
RmiProxyFactoryBean rmiProxy = new RmiProxyFactoryBean();
rmiProxy.setServiceUrl(rmiUrl + "/StockService");
rmiProxy.setServiceInterface(StockService.class);
return rmiProxy;
}
开发者ID:DevOpsDistilled,项目名称:OpERP,代码行数:8,代码来源:StockRmiContext.java
示例12: warehouseService
import org.springframework.remoting.rmi.RmiProxyFactoryBean; //导入依赖的package包/类
@Bean
public RmiProxyFactoryBean warehouseService() {
RmiProxyFactoryBean rmiProxy = new RmiProxyFactoryBean();
rmiProxy.setServiceUrl(rmiUrl + "/WarehouseService");
rmiProxy.setServiceInterface(WarehouseService.class);
return rmiProxy;
}
开发者ID:DevOpsDistilled,项目名称:OpERP,代码行数:8,代码来源:StockRmiContext.java
示例13: stockKeeperService
import org.springframework.remoting.rmi.RmiProxyFactoryBean; //导入依赖的package包/类
@Bean
public RmiProxyFactoryBean stockKeeperService() {
RmiProxyFactoryBean rmiProxy = new RmiProxyFactoryBean();
rmiProxy.setServiceUrl(rmiUrl + "/StockKeeperService");
rmiProxy.setServiceInterface(StockKeeperService.class);
return rmiProxy;
}
开发者ID:DevOpsDistilled,项目名称:OpERP,代码行数:8,代码来源:StockRmiContext.java
示例14: vendorService
import org.springframework.remoting.rmi.RmiProxyFactoryBean; //导入依赖的package包/类
@Bean
public RmiProxyFactoryBean vendorService() {
RmiProxyFactoryBean rmiProxy = new RmiProxyFactoryBean();
rmiProxy.setServiceUrl(rmiUrl + "/VendorService");
rmiProxy.setServiceInterface(VendorService.class);
return rmiProxy;
}
开发者ID:DevOpsDistilled,项目名称:OpERP,代码行数:8,代码来源:PartyRmiContext.java
示例15: customerService
import org.springframework.remoting.rmi.RmiProxyFactoryBean; //导入依赖的package包/类
@Bean
public RmiProxyFactoryBean customerService() {
RmiProxyFactoryBean rmiProxy = new RmiProxyFactoryBean();
rmiProxy.setServiceUrl(rmiUrl + "/CustomerService");
rmiProxy.setServiceInterface(CustomerService.class);
return rmiProxy;
}
开发者ID:DevOpsDistilled,项目名称:OpERP,代码行数:8,代码来源:PartyRmiContext.java
示例16: saleService
import org.springframework.remoting.rmi.RmiProxyFactoryBean; //导入依赖的package包/类
@Bean
public RmiProxyFactoryBean saleService() {
RmiProxyFactoryBean rmiProxy = new RmiProxyFactoryBean();
rmiProxy.setServiceInterface(SaleService.class);
String serviceName = rmiProxy.getServiceInterface().getCanonicalName();
rmiProxy.setServiceUrl(rmiUrl + "/" + serviceName);
return rmiProxy;
}
开发者ID:DevOpsDistilled,项目名称:OpERP,代码行数:9,代码来源:BusinessRmiContext.java
示例17: purchaseService
import org.springframework.remoting.rmi.RmiProxyFactoryBean; //导入依赖的package包/类
@Bean
public RmiProxyFactoryBean purchaseService() {
RmiProxyFactoryBean rmiProxy = new RmiProxyFactoryBean();
rmiProxy.setServiceInterface(PurchaseService.class);
String serviceName = rmiProxy.getServiceInterface().getCanonicalName();
rmiProxy.setServiceUrl(rmiUrl + "/" + serviceName);
return rmiProxy;
}
开发者ID:DevOpsDistilled,项目名称:OpERP,代码行数:9,代码来源:BusinessRmiContext.java
示例18: employeeService
import org.springframework.remoting.rmi.RmiProxyFactoryBean; //导入依赖的package包/类
@Bean
public RmiProxyFactoryBean employeeService() {
RmiProxyFactoryBean rmiProxy = new RmiProxyFactoryBean();
rmiProxy.setServiceInterface(EmployeeService.class);
String serviceName = rmiProxy.getServiceInterface().getCanonicalName();
rmiProxy.setServiceUrl(rmiUrl + "/" + serviceName);
return rmiProxy;
}
开发者ID:DevOpsDistilled,项目名称:OpERP,代码行数:9,代码来源:EmployeeRmiContext.java
示例19: payableAccountService
import org.springframework.remoting.rmi.RmiProxyFactoryBean; //导入依赖的package包/类
@Bean
public RmiProxyFactoryBean payableAccountService() {
RmiProxyFactoryBean rmiProxy = new RmiProxyFactoryBean();
rmiProxy.setServiceInterface(PayableAccountService.class);
String serviceName = rmiProxy.getServiceInterface().getCanonicalName();
rmiProxy.setServiceUrl(rmiUrl + "/" + serviceName);
return rmiProxy;
}
开发者ID:DevOpsDistilled,项目名称:OpERP,代码行数:9,代码来源:AccountRmiContext.java
示例20: receivableAccountService
import org.springframework.remoting.rmi.RmiProxyFactoryBean; //导入依赖的package包/类
@Bean
public RmiProxyFactoryBean receivableAccountService() {
RmiProxyFactoryBean rmiProxy = new RmiProxyFactoryBean();
rmiProxy.setServiceInterface(ReceivableAccountService.class);
String serviceName = rmiProxy.getServiceInterface().getCanonicalName();
rmiProxy.setServiceUrl(rmiUrl + "/" + serviceName);
return rmiProxy;
}
开发者ID:DevOpsDistilled,项目名称:OpERP,代码行数:9,代码来源:AccountRmiContext.java
注:本文中的org.springframework.remoting.rmi.RmiProxyFactoryBean类示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论