Openfire 使用RMI远程调用同步好友列表
1. 定义接口：
?
public interface RmiRemoteIntface extends Remote{
???
??? void deleteFriend(String user1, String user2) throws RemoteException;
???
??? String addFriend(String user1, String user2) throws RemoteException;
}
?
?
2. 实现接口
?
public class RmiRemoteObj extends UnicastRemoteObject implements
??? ??? RmiRemoteIntface {
??? protected RmiRemoteObj() throws RemoteException {
??? ??? super();
??? }
??? @Override
??? public void deleteFriend(String user1, String user2) throws RemoteException {
//??? ??? IQ iq = new IQ();
//??? ??? iq.setType(IQ.Type.set);
//??? ??? for (ClientSession session : XMPPServer.getInstance().getRoutingTable().getClientsRoutes(true)) {
//??? ??? ??? if (session.getAddress().getNode().equals(user1)) {
//??? ??? ??? ??? processDeleteMsg(iq, user2, session);
//??? ??? ??? } else if (session.getAddress().getNode().equals(user2)) {
//??? ??? ??? ??? processDeleteMsg(iq, user1, session);
//??? ??? ??? }
//??? ??? }
//??? ??? Element element = null;
??? }
???
??? public String addFriend(String user1, String user2) throws RemoteException{
//??? ??? IQ iq = new IQ();
//??? ??? iq.setType(IQ.Type.set);
//??? ??? for (ClientSession session : XMPPServer.getInstance().getRoutingTable().getClientsRoutes(true)) {
//??? ??? ??? if (session.getAddress().getNode().equals(user1)) {
//??? ??? ??? ??? processAddMsg(iq, user2, session);
//??? ??? ??? } else if (session.getAddress().getNode().equals(user2)) {
//??? ??? ??? ??? processAddMsg(iq, user1, session);
//??? ??? ??? }
??? ???
??? ??? System.out.println(user1+ " "+user2);
??? ??? return user1+" "+user2+? " hello world " ;
??? ??? }
?
?
3. 编写RmiServer
?
public class RmiServer extends Thread{
??? public static int rmi = 0;
??? public static RmiServer rmiServer;
??? static{
??????? rmiServer = new RmiServer();
??????? rmiServer.setDaemon(false);
??????? rmiServer.start();
??? }
???
??? public static void main(String args[]){
??? ??? //创建并安装安全管理器
//??? ??? if(System.getSecurityManager() == null){
//??? ??? ??? System.setSecurityManager(new RMISecurityManager());
//??? ??? }
??? ??? try{
??? ??? ??? LocateRegistry.createRegistry(8057);
??? ??? ??? //创建远程对象
??? ??? ??? RmiRemoteIntface rro = new RmiRemoteObj();
??? ??? ??? //将实例注册到专有的URL
??? ??? ??? Naming.rebind("//127.0.0.1:8057/RmiRemoteObj", rro);
??? ??? ???
??? ??? ??? System.out.println("RMI服务器正在运行...");
??? ??? }catch(Exception e){
??? ??? ??? e.printStackTrace();
??? ??? }
??? }
???
??? public void run(){
??? ??? try{
??? ??? ??? LocateRegistry.createRegistry(8057);
??? ??? ??? //创建远程对象
??? ??? ??? RmiRemoteIntface rro = new RmiRemoteObj();
??? ??? ??? //将实例注册到专有的URL
??? ??? ??? Naming.rebind("//127.0.0.1:8057/RmiRemoteObj", rro);
??? ??? ???
??? ??? ??? System.out.println("RMI服务器正在运行...");
??? ??? }catch(Exception e){
??? ??? ??? e.printStackTrace();
??? ??? }
??? }
?
?
4. 编写RmiClient
?
public class RmiClient {
??? public static void main(String args[]){
??? ??? //创建并安装安全管理器
//??? ??? if(System.getSecurityManager()==null)
//??? ??? {
//??? ?????? System.setSecurityManager(new RMISecurityManager());
//??? ??? }
??? ??? String host = "rmi://127.0.0.1:8057/RmiRemoteObj";
//??? ??? String host = "rmi://192.168.1.103:2099/RmiRemoteObj";
//??? ??? String host = "rmi://192.168.1.119:2099/RmiRemoteObj";
//??? ??? if(args.length > 0){
//??? ??? ??? host = args[0];
//??? ??? }
??? ???
??? ??? try{
??? ??? ??? //根据制定的URL定位远程对象
??? ??? ??? RmiRemoteIntface rri = (RmiRemoteIntface)Naming.lookup(host);
//??? ??? ??? rri.addFriend("test01", "test02");
??? ??? ??? System.out.println(rri.addFriend("aaaaaaa", "ccc"));
//??? ??? ??? rri.deleteFriend("admin", "kocko");
??? ??? ??? System.out.println("调用成功！");
??? ??? }catch(Exception e){
??? ??? ??? e.printStackTrace();
??? ??? }
??? }
?
5. 在Openfire启动时加载Rmi服务
??? 在类org.jivesoftware.openfire.spi.ConnectionManagerImpl 的方法?? startListeners(）startHTTPBindListeners后面加上RmiServer rmi = new RmiServer();
??? 搞定！
RmiServer rmi = new RmiServer();
