CORBA例使用不同的JDK(闭合)(CORBA example uses a different

2019-10-20 18:18发布

从目前的CORBA例如http://www.oracle.com/technetwork/articles/javase/rmi-corba-136641.html

使用differet JDK版本。 我使用JDK 1.7

所以,问题是我已经扩展了类extends FileInterfacePOA ,而不是extends _FileInterfaceImplBase

所以,现在我在服务器代码我应该使用什么而不是函数得到一个错误.connect().rebind()

服务器的代码是:

import java.io.*;
import org.omg.CosNaming.*;
import org.omg.CosNaming.NamingContextPackage.*;
import org.omg.CORBA.*;

public class StartServer {
   public static void main(String args[]) {
      try{
         // create and initialize the ORB
         ORB orb = ORB.init(args, null);
         // create the servant and register it with the ORB
         FileTransferObj fileRef = new FileTransferObj();
         orb.connect(fileRef);
         // get the root naming context
         org.omg.CORBA.Object objRef =
            orb.resolve_initial_references("NameService");
         NamingContext ncRef = NamingContextHelper.narrow(objRef);
         // Bind the object reference in naming
         NameComponent nc = new NameComponent("FileTransfer", " ");
         NameComponent path[] = {nc};
         ncRef.rebind(path, fileRef);
         System.out.println("Server started....");
         // Wait for invocations from clients
         java.lang.Object sync = new java.lang.Object();
         synchronized(sync){
            sync.wait();
         }
      } catch(Exception e) {
         System.err.println("ERROR: " + e.getMessage());
         e.printStackTrace(System.out);
      }
   }
}

接口代码:

import FileTransferApp.*;``
import org.omg.CosNaming.*;
import org.omg.CosNaming.NamingContextPackage.*;
import org.omg.CORBA.*;
import org.omg.PortableServer.*;
import org.omg.PortableServer.POA;
import java.util.Properties;


    import java.io.BufferedInputStream;
    import java.io.File;
    import java.io.FileInputStream;

public class FileTransferObj extends FileInterfacePOA {
       public byte[] downloadFile(String fileName){
              File file = new File(fileName);
              byte buffer[] = new byte[(int)file.length()];
              try {
                 BufferedInputStream input = new
                   BufferedInputStream(new FileInputStream(argv[0]));
                 input.read(buffer,0,buffer.length);

              } catch(Exception e) {
                 System.out.println("FileServant Error: "+e.getMessage());
                 e.printStackTrace();
              }
              return(buffer); 
           }
        }

Answer 1:

如此以来,JDK版本是不同的形式我也跟着例子。 下列变更将解决这个问题。

import org.omg.CORBA.ORB;
import org.omg.CosNaming.NameComponent;
import org.omg.CosNaming.NamingContext;
import org.omg.CosNaming.NamingContextExt;
import org.omg.CosNaming.NamingContextExtHelper;
import org.omg.CosNaming.NamingContextHelper;
import org.omg.PortableServer.POA;
import org.omg.PortableServer.POAHelper;

import FileTransferApp.*;

public class StartServer {
   public static void main(String args[]) {
      try{
         // create and initialize the ORB
         ORB orb = ORB.init(args, null);
         POA rootpoa = POAHelper.narrow(orb.resolve_initial_references("RootPOA"));
         rootpoa.the_POAManager().activate();

         // create the servant and register it with the ORB
         FileTransferObj fileRef = new FileTransferObj();
         fileRef.setORB(orb);

         //get Object reference from servant
         org.omg.CORBA.Object ref =  rootpoa.servant_to_reference(fileRef);
         FileInterface href = FileInterfaceHelper.narrow(ref);

         // get the root naming context
         org.omg.CORBA.Object objRef =
            orb.resolve_initial_references("NameService");
         NamingContextExt ncRef = NamingContextExtHelper.narrow(objRef);

         //
         NameComponent path[] = ncRef.to_name("ABC");
         ncRef.rebind(path, href);

         System.out.println("Server started....");
         // Wait for invocations from clients
         for(;;){
            orb.run();
         }
      } catch(Exception e) {
         System.err.println("ERROR: " + e.getMessage());
         e.printStackTrace(System.out);
      }
   }
}


文章来源: CORBA example uses a different JDK [closed]