学步园

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服务监视的默认端口

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>

<!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;

}

}

<!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的RMI客户端Bean配置文件获取服务对象时出现异常：" + e);

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

}

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

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

return bln;

}