java RMI入门指南「建议收藏」

public
 
interface
 IHello 
extends
 Remote {

public
 String sayHello(String name) 
throws
 java.rmi.RemoteException;

}

import
 java.rmi.RemoteException;

public
 
interface
 IFileUtil 
extends
 Remote {

public
 
byte
[] downloadFile(String fileName) 
throws
 RemoteException;

}

import
 java.io.File;

import
 java.io.FileInputStream;

import
 java.rmi.RemoteException;

import
 java.rmi.server.UnicastRemoteObject;

public
 
class
 FileUtilImpl 
extends
 UnicastRemoteObject 
implements
 IFileUtil {

protected
 FileUtilImpl() 
throws
 RemoteException {

super
();

}

private
 
static
 
final
 
long
 serialVersionUID 
=
 
7594622080290821912L
;

public
 
byte
[] downloadFile(String fileName) 
throws
 RemoteException{

File file 
=
 
new
 File(fileName);

byte
 buffer[] 
=
 
new
 
byte
[(
int
) file.length()];

int
 size 
=
 buffer.length;

System.out.println(
“
download file size = 
“
+
size 
+
“
b
“
);

if
(size
>
1024
*
1024
*
10
){
//
限制文件大小不能超过10M。文件太大可能导制内存溢出。




throw
 
new
 RemoteException(
“
Error:<The File is too big!>
“
);

}

try
 {

BufferedInputStream input 
=
 
new
 BufferedInputStream(

new
 FileInputStream(fileName));

input.read(buffer, 
0
, buffer.length);

input.close();

System.out.println(
“
Info:<downloadFile() hed execute successful!>
“
);

return
 buffer;

} 
catch
 (Exception e) {

System.out.println(
“
FileUtilImpl: 
“
 
+
 e.getMessage());

e.printStackTrace();

return
 
null
;

}

}

}

import
 java.rmi.RMISecurityManager;

public
 
class
 FileUtilServer {

public
 
static
 
void
 main(String argv[]) {

try
 {

IFileUtil file 
=
 
new
 FileUtilImpl();

//
LocateRegistry.createRegistry(1099); 
//
加上此程序。就能够不要在控制台上开启RMI的注冊程序。1099是RMI服务监视的默认port



Naming.rebind(
“
rmi://127.0.0.1/FileUtilServer
“
, file);

System.out.print(
“
Ready
“
);

} 
catch
 (Exception e) {

System.out.println(
“
FileUtilServer: 
“
 
+
 e.getMessage());

e.printStackTrace();

}
}
}

import
 java.io.File;

import
 java.io.FileOutputStream;

import
 java.rmi.Naming;

public
 
class
 FileUtilClient {

public
 
static
 
void
 main(String args[]) {

if
 (args.length 
!=
 
3
) {

System.out.println(
“
第一个參数：RMI服务的IP地址
“
);

System.out.println(
“
第二个參数：要下载的文件名称
“
);

System.out.println(
“
第三个參数：要文件保存位置
“
);

System.exit(
0
);

}

try
 {

String name 
=
 
“
rmi://
“
 
+
 args[
0
] 
+
 
“
/FileUtilServer
“
;

IFileUtil fileUtil 
=
 (IFileUtil) Naming.lookup(name);

byte
[] filedata 
=
 fileUtil.downloadFile(args[
1
]);

if
(filedata
==
null
){

System.out.println(
“
Error：<filedata is null!>
“
);

System.exit(
0
);

}

File file 
=
 
new
 File(args[
2
]);

System.out.println(
“
file.getAbsolutePath() = 
“
+
file.getAbsolutePath());

BufferedOutputStream output 
=
 
new
 BufferedOutputStream(

new
 FileOutputStream(file.getAbsolutePath()));

output.write(filedata, 
0
, filedata.length);

output.flush();

output.close();

System.out.println(
“
~~~~~End~~~~~
“
);

} 
catch
 (Exception e) {

System.err.println(
“
FileUtilServer exception: 
“
 
+
 e.getMessage());

e.printStackTrace();

}

}

}

    
<!–
 any additional properties, maybe a DAO? 
–>

</
bean
>

<!–
 does not necessarily have to be the same name as the bean to be exported 
–>

<
property 
name
=”serviceName”
 value
=”AccountService”
/>

<
property 
name
=”service”
 ref
=”accountService”
/>

<
property 
name
=”serviceInterface”
 value
=”example.AccountService”
/>

<!–
 defaults to 1099 
–>

<
property 
name
=”registryPort”
 value
=”1199″
/>

</
bean
>

  
private
 AccountService accountService;

  
public
 
void
 setAccountService(AccountService accountService) {

    
this
.accountService 
=
 accountService;

  }

}

<
property 
name
=”accountService”
 ref
=”accountService”
/>

</
bean
>

<
bean 
id
=”accountService”
 class
=”org.springframework.remoting.rmi.RmiProxyFactoryBean”
>

<
property 
name
=”serviceUrl”
 value
=”rmi://HOST:1199/AccountService”
/>

<
property 
name
=”serviceInterface”
 value
=”example.AccountService”
/>

</
bean
>

xml version=”1.0″ encoding=”UTF-8″?>

<!DOCTYPE beans PUBLIC “-//SPRING//DTD BEAN 2.0//EN” “http://www.springframework.org/dtd/spring-beans-2.0.dtd”>

<beans default-autowire=”byName” default-lazy-init=”false”>

<!– service实现类的配置 –>

<bean id=”fbWebService” class=”com.ce.omas.interfaces.service.impl.FeedbackWebServiceImpl” />

<bean class=”org.springframework.remoting.rmi.RmiServiceExporter”>

<!– does not necessarily have to be the same name as the bean to be exported –>

<property name=”serviceName” value=”FeedbackRMIService” />

<property name=”service” ref=”fbWebService” />

<property name=”serviceInterface” value=”com.ce.omas.interfaces.service.IFeedbackWebService” />

<!– <property name=”registryHost” value=”rmi://192.168.100.7″/> –>

<!– defaults to 1099 –>

<property name=”registryPort” value=”1199″ />

</bean>

</beans>

/**

 * <b>方法用途和描写叙述:</b> 客户反馈RMI服务端接口方法<br>

 * <b>方法的实现逻辑描写叙述：</b> 通过RMI提供服务，Spring支持的RMI远程调用

 * 
@param
 systemID : 业务系统的唯一标识

 * 
@param
 feedbackType ：用户反馈的类型（1-系统BUG、2-系统易用性、3-客服人员态度、4-运维人员态度、5-其它）

 * 
@param
 feedbackContent ：用户反馈的正文内容

 * 
@return
 反馈是否成功 true | false

 
*/

public
 
boolean
 setFeedback(String systemID, FeedbackType feedbackType,

String feedbackContent) 
throws
 OMASServiceException ;

}

private
 
static
 Log _log 
=
 LogFactory.getLog(FeedbackWebServiceImpl.
class
);

private
 
static
 
final
 
long
 serialVersionUID 
=
 
–
5532505108644974594L
;

/**

 * 客户反馈服务接口

 
*/

private
 IFeedbackOperationService feedbackService;

/**

* 方法用途和描写叙述: 注入运营模块的加入客户反馈的服务

* 
@param
 feedbackWebService 运营模块服务

 
*/

public
 
void
 setFeedbackService(IFeedbackOperationService feedbackWebService) {

_log.info(
“
注入运营模块的加入客户反馈的服务
“
);

this
.feedbackService 
=
 feedbackWebService;

}

/**

* 方法用途和描写叙述: 外部接口子系统中加入客户反馈的方法

* 
@param
 systemID ：业务系统ID

* 
@param
 feedbackType ：反馈类型

* 
@param
 feedbackContent ：反馈内容

* 
@return
 操作是否成功 ture or false

 * 
@throws
 ServiceException 

 
*/

public
 
boolean
 setFeedback(String systemID, FeedbackType feedbackType, String feedbackContent) 
throws
 OMASServiceException {

_log.info(
“
进入到外部接口的加入客户反馈的方法
“
);

if
 (BlankUtil.isBlank(systemID) 
||
 BlankUtil.isBlank(feedbackType)

||
 BlankUtil.isBlank(feedbackContent)) {

_log.error(
“
加入客户反馈的接口參数为空！

“);

throw new OMASServiceException(“omas.interfaces.001“);//加入客户反馈的接口參数为空

}

WebServiceFeedbackVO vo = new WebServiceFeedbackVO();

vo.setFeedbackType(String.valueOf(feedbackType.getValue()));

vo.setFeedbackContent(feedbackContent);

vo.setSystemID(systemID);

_log.info(“调用运营子系统的加入客户反馈的方法開始！

“);

try {

if (feedbackService == null) {

_log.error(“运营模块服务为空“);

throw new OMASServiceException(“omas.interfaces.002“);//运营模块服务为空

}

feedbackService.addFeedbackOperation(vo);

} catch (ServiceException e) {

_log.error(“调用运营子系统的加入客户反馈出现异常：“+e.getMessage());

if(ExceptionConstants.EXCEPTION_OMAS_FEEDBACK_VO.equals(e.getMsgKey())){//客户调用接口的对像为空

throw new OMASServiceException(“omas.interfaces.003“);

} if(ExceptionConstants.EXCEPTION_OMAS_FEEDBACK_SYSTEMID.equals(e.getMsgKey())){//业务系统标识ID为空

throw new OMASServiceException(“omas.omasservice.010“);

} if(ExceptionConstants.EXCEPTION_OMAS_FEEDBACK_SIZE.equals(e.getMsgKey())){//非法的业务系统唯一标识

throw new OMASServiceException(“omas.interfaces.004“);

} if(ExceptionConstants.EXCEPTION_OMAS_FEEDBACK_BASE.equals(e.getMsgKey())){//数据库訪问出了一点小问题！

throw new OMASServiceException(“omas.interfaces.005“);

}

throw new OMASServiceException(“omas.omasservice.000“);//未捕获到的异常信息。

}

return true;

}

}

xml version=”1.0″ encoding=”UTF-8″?>

<!DOCTYPE beans PUBLIC “-//SPRING//DTD BEAN 2.0//EN” “http://www.springframework.org/dtd/spring-beans-2.0.dtd”>

<beans default-autowire=”byName” default-lazy-init=”true”>

<bean id=”fbWebServiceProxy”

class=”org.springframework.remoting.rmi.RmiProxyFactoryBean”>

<property name=”serviceUrl”>

<value>rmi://127.0.0.1:1199/FeedbackRMIService</value>

</property>

<property name=”serviceInterface”>

<value>com.ce.omas.interfaces.service.IFeedbackWebService</value>

</property>

</bean>

<bean class=”com.ce.omas.omasservice.service.impl.FeedbackRMIClientImpl”>

<property name=”feedbackWebService” ref=”fbWebServiceProxy” />

</bean>

</beans>

* 方法用途和描写叙述: 客户反馈：通过RMI方法与OMAS通讯

* 方法的实现逻辑描写叙述：

* 
@param
 feedbackType

* 
@param
 feedbackContent

* 
@return

* 
@throws
 OMASServiceException

*/

public
 
static
 
boolean
 setFeedback_RMIClient(String systemID, FeedbackType feedbackType, String feedbackContent) 
throws
 OMASServiceException {

if
 (systemID 
==
 
null
 
||
 
“”
.equals(systemID)) {

_log.error(
“
业务系统标识<SystemID>为空或不是对象
“
);

throw
 
new
 OMASServiceException(
“
omas.omasservice.010
“
);

}

String rmiClientConfigFilePath 
=
 PropertyReader .getValue(ConfigConstants.OMASSERVICE_CONFIG_PATH, ConfigConstants.RMI_CLIENT_CONFIG_FILEPATH);

if
 (rmiClientConfigFilePath 
==
 
null
 
||
 
“”
.equals(rmiClientConfigFilePath)) {

_log.error(
“
配置文件错误：Key<rmiClientConfigFile>为空或不存在
“
);

throw
 
new
 OMASServiceException(
“
omas.omasservice.006
“
);

}

_log.info(
“
rmiClientConfigPath = 
“
 
+
 rmiClientConfigFilePath);

ApplicationContext context 
=
 
null
;

try
 {

context = new ClassPathXmlApplicationContext(rmiClientConfigFilePath);

} 
catch
 (Exception e) {

_log.error(
“
客户反馈：解析rmi-config.xml文件时出现异常：
“
 
+
 e);

_log.info(
“
rmi-config.xml文件路径：
“
+
rmiClientConfigFilePath);

throw
 
new
 OMASServiceException(
“
omas.omasservice.007
“
);

}

IFeedbackWebService service 
=
 
null
;

try
 {

service = (IFeedbackWebService) context .getBean(“fbWebServiceProxy”);

} 
catch
 (Exception e) {

_log.error(
“
从Spring的RMIclientBean配置文件获取服务对象时出现异常：
“
 
+
 e);

throw
 
new
 OMASServiceException(
“
omas.omasservice.009
“
);

}

boolean
 bln 
=
 service.setFeedback(systemID, feedbackType, feedbackContent);

_log.info(
“
反馈操作是否成功[true|false]：
“
 
+
 bln);

return
 bln;

}