当前位置： 文江博客话题详情

为什么我的 CORBA 服务器没有绑定？

发布于 2024-09-25 11:11:23 字数 9486 浏览 5 评论 0原文

目前正在尝试完成 SAMS 的第 4 章 - 在 14 天内自学 CORBA。

书中的代码似乎可以工作，只是它没有按预期停止，而是输出“无法绑定 StockServer：”

为了解决此问题，我修改了本书以使用 POA 并启动了 tnameserv，但是问题遗迹。

这是我键入和修改的代码，而不是使用 idlj“编译”（生成）：

// StockServerImpl.java

package StockMarket;

import java.util.Vector;

import org.omg.CORBA.*;
import org.omg.CORBA.Object;
import org.omg.CosNaming.NameComponent;
import org.omg.CosNaming.NamingContext;
import org.omg.CosNaming.NamingContextHelper;


/**
* StockMarket/StockServer.java .
* Generated by the IDL-to-Java compiler (portable), version "3.2"
* from StockMarket.idl
* Thursday, 30 September 2010 14:40:36 o'clock CEST
*/


// StockServerImpl implements the StockServer IDL interface
public class StockServerImpl
    extends StockServerPOA
    //extends _StockServerImplBase 
    implements StockServer 
{
    /**
     * 
     */
    private static final long serialVersionUID = 1L;
    // Stock symbols and their respective values.
    private Vector<String> myStockSymbols;
    private Vector<Float> myStockValues;

    // Characters from which StockSymbol names are built.
    private static char ourCharacters[] = 
    { 
                         'A', 'B', 'C', 'D', 'E', 'F', 'G', 'H', 'I',
                         'J', 'K', 'L', 'M', 'N', 'O', 'P', 'Q', 'R',
                         'S', 'T', 'U', 'V', 'W', 'X', 'Y', 'Z' 
    };

    // Path name for StockServer objects.
    private static String ourPathName = "StockServer";

    // Create a new StockServerImpl.
    public StockServerImpl()
    {
        myStockSymbols = new Vector<String>();
        myStockValues = new Vector<Float>();

        // Initialize the symbols and values with some random values.
        for (int i=0; i<10; i++)
        {
            // Generate a string of four random characters.
            StringBuffer stockSymbol = new StringBuffer("    ");
            for (int j=0; j<4; j++)
                { stockSymbol.setCharAt(j, ourCharacters[(int) (Math.random() * 26f)]); }

            myStockSymbols.addElement(stockSymbol.toString());

            // Give the stock a value between 0 and 100.  In this example,
            // the stock will retain this value for the duration of the
            // application.
            myStockValues.addElement(new Float(Math.random() * 100f));
        }

        // Print out the stock symbols generated above.
        System.out.println("Generated stock symbols:");
        for (int i=0; i<10; i++)
            { 
                System.out.println( 
                                    " " + myStockSymbols.elementAt(i) 
                                  + " " + myStockValues.elementAt(i)
                );
            } 
        System.out.println();
    }

    // Return the current value for the given StockSymbol.
    @Override
    public float getStockValue(String symbol) throws InvalidStockSymbolException 
    {
        // Try to find the given symbol.
        int stockIndex = myStockSymbols.indexOf(symbol);
        if (stockIndex != -1)
        {
            // Symbol found; return its value.
            return (myStockValues.elementAt(stockIndex).floatValue());
        }
        else
        {
            // Symbol was not found.
            throw new InvalidStockSymbolException();
        }
    }

    // Return a sequence of all StockSymbols known by this StockServer.
    @Override
    public String[] getStockSymbols() 
    {
        String[] symbols = new String[myStockSymbols.size()];
        myStockSymbols.copyInto(symbols);
        return symbols;
    }

    /**
     * @param ourPathName the ourPathName to set
     */
    public static void setOurPathName(String ourPathName) {
        StockServerImpl.ourPathName = ourPathName;
    }

    /**
     * @return the ourPathName
     */
    public static String getOurPathName() {
        return ourPathName;
    }

    // Create and initialize a StockServer object.
    public static void main (String args[])
    {
        NameComponent nameComponent = null;
        NamingContext namingContext = null;
        ORB orb = null;
        org.omg.CORBA.Object obj = null;
        StockServerImpl stockServer = null;

        try { orb = ORB.init(args, null); } // Initialize the ORB.
        catch (Exception ex) { System.err.println("Can't initialize ORB: " + ex.getMessage());}

        try { stockServer = new StockServerImpl(); } // Create a StockServerImpl object and register it with the ORB.
        catch (Exception ex) { System.err.println("Can't create StockServer: " + ex.getMessage()); }

        try { orb.connect(stockServer); }
        catch (Exception ex) { System.err.println("Can't connect ORB to StockServer: " + ex.getMessage()); ex.printStackTrace(); }

        try { obj = orb.resolve_initial_references("NameService"); } // Get the root naming context.
        catch (Exception ex) { System.err.println("Can't resolve NameServeice: " + ex.getMessage());  ex.printStackTrace();}

        try { namingContext = NamingContextHelper.narrow(obj); }
        catch (Exception ex) { System.err.println("Can't narrow NamingContext: " + ex.getMessage()); }

        try { nameComponent = new NameComponent (ourPathName, ""); } // Bind the StockServer object reference in the naming context
        catch (Exception ex) { System.err.println("Can't create NameComponent: " + ex.getMessage()); }

        NameComponent path[] = { nameComponent };

        try { namingContext.rebind(path, stockServer); }
        catch (Exception ex) { System.err.println("Can't rebind NameComponent to StockServer: " + ex.getMessage()); ex.printStackTrace(); }

        // Wait for invocations from clients.
        java.lang.Object waitOnMe = new java.lang.Object();
        synchronized(waitOnMe) 
        { 
            try { waitOnMe.wait(); } 
            catch (InterruptedException ex) 
            {
                System.err.println("Can't wait: " + ex.getMessage());
                ex.printStackTrace();
            } 
        }
    }

    @Override
    public Request _create_request(Context ctx, String operation,
            NVList arg_list, NamedValue result) {
        // TODO Auto-generated method stub
        return null;
    }

    @Override
    public Request _create_request(Context ctx, String operation,
            NVList arg_list, NamedValue result, ExceptionList exclist,
            ContextList ctxlist) {
        // TODO Auto-generated method stub
        return null;
    }

    @Override
    public Object _duplicate() {
        // TODO Auto-generated method stub
        return null;
    }

    @Override
    public DomainManager[] _get_domain_managers() {
        // TODO Auto-generated method stub
        return null;
    }

    @Override
    public Policy _get_policy(int policy_type) {
        // TODO Auto-generated method stub
        return null;
    }

    @Override
    public int _hash(int maximum) {
        // TODO Auto-generated method stub
        return 0;
    }

    @Override
    public boolean _is_equivalent(Object other) {
        // TODO Auto-generated method stub
        return false;
    }

    @Override
    public void _release() {
        // TODO Auto-generated method stub

    }

    @Override
    public Request _request(String operation) {
        // TODO Auto-generated method stub
        return null;
    }

    @Override
    public Object _set_policy_override(Policy[] policies,
            SetOverrideType set_add) {
        // TODO Auto-generated method stub
        return null;
    }
} // interface StockServer

这是我的控制台输出，包括堆栈跟踪：

 Generated stock symbols:
 WION 56.691833
 KQEJ 40.678604
 HCBM 82.15452
 VERC 30.731018
 LEAR 11.632088
 QLCV 58.973534
 FJDO 57.708836
 SVPS 29.638231
 NNGN 27.48113
 UAWE 65.20851

Can't connect ORB to StockServer: 
org.omg.CORBA.OBJ_ADAPTER:   vmcid: SUN  minor code: 202  completed: No
    at com.sun.corba.se.impl.logging.ORBUtilSystemException.orbConnectError(Unknown Source)
    at com.sun.corba.se.impl.logging.ORBUtilSystemException.orbConnectError(Unknown Source)
    at com.sun.corba.se.impl.orb.ORBImpl.connect(Unknown Source)
    at StockMarket.StockServerImpl.main(StockServerImpl.java:137)
Caused by: org.omg.CORBA.BAD_OPERATION:   vmcid: SUN  minor code: 240  completed: No
    at com.sun.corba.se.impl.logging.ORBUtilSystemException.getTypeIdsRequiresStub(Unknown Source)
    at com.sun.corba.se.impl.logging.ORBUtilSystemException.getTypeIdsRequiresStub(Unknown Source)
    at com.sun.corba.se.spi.presentation.rmi.StubAdapter.getTypeIds(Unknown Source)
    at com.sun.corba.se.impl.oa.toa.TOAImpl.connect(Unknown Source)
    ... 2 more
Can't rebind NameComponent to StockServer: 
org.omg.CORBA.BAD_PARAM:   vmcid: SUN  minor code: 206  completed: No
    at com.sun.corba.se.impl.logging.ORBUtilSystemException.localObjectNotAllowed(Unknown Source)
    at com.sun.corba.se.impl.logging.ORBUtilSystemException.localObjectNotAllowed(Unknown Source)
    at com.sun.corba.se.impl.orbutil.ORBUtility.getIOR(Unknown Source)
    at com.sun.corba.se.impl.orbutil.ORBUtility.connectAndGetIOR(Unknown Source)
    at com.sun.corba.se.impl.encoding.CDROutputStream_1_0.write_Object(Unknown Source)
    at com.sun.corba.se.impl.encoding.CDROutputStream.write_Object(Unknown Source)
    at org.omg.CORBA.ObjectHelper.write(Unknown Source)
    at org.omg.CosNaming._NamingContextExtStub.rebind(Unknown Source)
    at StockMarket.StockServerImpl.main(StockServerImpl.java:151)
原文

Currently trying to work my way through Chapter 4 of SAMS - Teach Yourself CORBA in 14 Days.

The code from the book seems to work, except rather than stopping as expected, it spits out "Couldn't bind StockServer: "

In an attempt to resolve this issue, I modified the book to use POA and I started tnameserv, but the issue remains.

Here is the code I typed and modified, instead of "compiled" (generated) with idlj:

// StockServerImpl.java

package StockMarket;

import java.util.Vector;

import org.omg.CORBA.*;
import org.omg.CORBA.Object;
import org.omg.CosNaming.NameComponent;
import org.omg.CosNaming.NamingContext;
import org.omg.CosNaming.NamingContextHelper;


/**
* StockMarket/StockServer.java .
* Generated by the IDL-to-Java compiler (portable), version "3.2"
* from StockMarket.idl
* Thursday, 30 September 2010 14:40:36 o'clock CEST
*/


// StockServerImpl implements the StockServer IDL interface
public class StockServerImpl
    extends StockServerPOA
    //extends _StockServerImplBase 
    implements StockServer 
{
    /**
     * 
     */
    private static final long serialVersionUID = 1L;
    // Stock symbols and their respective values.
    private Vector<String> myStockSymbols;
    private Vector<Float> myStockValues;

    // Characters from which StockSymbol names are built.
    private static char ourCharacters[] = 
    { 
                         'A', 'B', 'C', 'D', 'E', 'F', 'G', 'H', 'I',
                         'J', 'K', 'L', 'M', 'N', 'O', 'P', 'Q', 'R',
                         'S', 'T', 'U', 'V', 'W', 'X', 'Y', 'Z' 
    };

    // Path name for StockServer objects.
    private static String ourPathName = "StockServer";

    // Create a new StockServerImpl.
    public StockServerImpl()
    {
        myStockSymbols = new Vector<String>();
        myStockValues = new Vector<Float>();

        // Initialize the symbols and values with some random values.
        for (int i=0; i<10; i++)
        {
            // Generate a string of four random characters.
            StringBuffer stockSymbol = new StringBuffer("    ");
            for (int j=0; j<4; j++)
                { stockSymbol.setCharAt(j, ourCharacters[(int) (Math.random() * 26f)]); }

            myStockSymbols.addElement(stockSymbol.toString());

            // Give the stock a value between 0 and 100.  In this example,
            // the stock will retain this value for the duration of the
            // application.
            myStockValues.addElement(new Float(Math.random() * 100f));
        }

        // Print out the stock symbols generated above.
        System.out.println("Generated stock symbols:");
        for (int i=0; i<10; i++)
            { 
                System.out.println( 
                                    " " + myStockSymbols.elementAt(i) 
                                  + " " + myStockValues.elementAt(i)
                );
            } 
        System.out.println();
    }

    // Return the current value for the given StockSymbol.
    @Override
    public float getStockValue(String symbol) throws InvalidStockSymbolException 
    {
        // Try to find the given symbol.
        int stockIndex = myStockSymbols.indexOf(symbol);
        if (stockIndex != -1)
        {
            // Symbol found; return its value.
            return (myStockValues.elementAt(stockIndex).floatValue());
        }
        else
        {
            // Symbol was not found.
            throw new InvalidStockSymbolException();
        }
    }

    // Return a sequence of all StockSymbols known by this StockServer.
    @Override
    public String[] getStockSymbols() 
    {
        String[] symbols = new String[myStockSymbols.size()];
        myStockSymbols.copyInto(symbols);
        return symbols;
    }

    /**
     * @param ourPathName the ourPathName to set
     */
    public static void setOurPathName(String ourPathName) {
        StockServerImpl.ourPathName = ourPathName;
    }

    /**
     * @return the ourPathName
     */
    public static String getOurPathName() {
        return ourPathName;
    }

    // Create and initialize a StockServer object.
    public static void main (String args[])
    {
        NameComponent nameComponent = null;
        NamingContext namingContext = null;
        ORB orb = null;
        org.omg.CORBA.Object obj = null;
        StockServerImpl stockServer = null;

        try { orb = ORB.init(args, null); } // Initialize the ORB.
        catch (Exception ex) { System.err.println("Can't initialize ORB: " + ex.getMessage());}

        try { stockServer = new StockServerImpl(); } // Create a StockServerImpl object and register it with the ORB.
        catch (Exception ex) { System.err.println("Can't create StockServer: " + ex.getMessage()); }

        try { orb.connect(stockServer); }
        catch (Exception ex) { System.err.println("Can't connect ORB to StockServer: " + ex.getMessage()); ex.printStackTrace(); }

        try { obj = orb.resolve_initial_references("NameService"); } // Get the root naming context.
        catch (Exception ex) { System.err.println("Can't resolve NameServeice: " + ex.getMessage());  ex.printStackTrace();}

        try { namingContext = NamingContextHelper.narrow(obj); }
        catch (Exception ex) { System.err.println("Can't narrow NamingContext: " + ex.getMessage()); }

        try { nameComponent = new NameComponent (ourPathName, ""); } // Bind the StockServer object reference in the naming context
        catch (Exception ex) { System.err.println("Can't create NameComponent: " + ex.getMessage()); }

        NameComponent path[] = { nameComponent };

        try { namingContext.rebind(path, stockServer); }
        catch (Exception ex) { System.err.println("Can't rebind NameComponent to StockServer: " + ex.getMessage()); ex.printStackTrace(); }

        // Wait for invocations from clients.
        java.lang.Object waitOnMe = new java.lang.Object();
        synchronized(waitOnMe) 
        { 
            try { waitOnMe.wait(); } 
            catch (InterruptedException ex) 
            {
                System.err.println("Can't wait: " + ex.getMessage());
                ex.printStackTrace();
            } 
        }
    }

    @Override
    public Request _create_request(Context ctx, String operation,
            NVList arg_list, NamedValue result) {
        // TODO Auto-generated method stub
        return null;
    }

    @Override
    public Request _create_request(Context ctx, String operation,
            NVList arg_list, NamedValue result, ExceptionList exclist,
            ContextList ctxlist) {
        // TODO Auto-generated method stub
        return null;
    }

    @Override
    public Object _duplicate() {
        // TODO Auto-generated method stub
        return null;
    }

    @Override
    public DomainManager[] _get_domain_managers() {
        // TODO Auto-generated method stub
        return null;
    }

    @Override
    public Policy _get_policy(int policy_type) {
        // TODO Auto-generated method stub
        return null;
    }

    @Override
    public int _hash(int maximum) {
        // TODO Auto-generated method stub
        return 0;
    }

    @Override
    public boolean _is_equivalent(Object other) {
        // TODO Auto-generated method stub
        return false;
    }

    @Override
    public void _release() {
        // TODO Auto-generated method stub

    }

    @Override
    public Request _request(String operation) {
        // TODO Auto-generated method stub
        return null;
    }

    @Override
    public Object _set_policy_override(Policy[] policies,
            SetOverrideType set_add) {
        // TODO Auto-generated method stub
        return null;
    }
} // interface StockServer

Here is my console output, including stacktraces:

 Generated stock symbols:
 WION 56.691833
 KQEJ 40.678604
 HCBM 82.15452
 VERC 30.731018
 LEAR 11.632088
 QLCV 58.973534
 FJDO 57.708836
 SVPS 29.638231
 NNGN 27.48113
 UAWE 65.20851

Can't connect ORB to StockServer: 
org.omg.CORBA.OBJ_ADAPTER:   vmcid: SUN  minor code: 202  completed: No
    at com.sun.corba.se.impl.logging.ORBUtilSystemException.orbConnectError(Unknown Source)
    at com.sun.corba.se.impl.logging.ORBUtilSystemException.orbConnectError(Unknown Source)
    at com.sun.corba.se.impl.orb.ORBImpl.connect(Unknown Source)
    at StockMarket.StockServerImpl.main(StockServerImpl.java:137)
Caused by: org.omg.CORBA.BAD_OPERATION:   vmcid: SUN  minor code: 240  completed: No
    at com.sun.corba.se.impl.logging.ORBUtilSystemException.getTypeIdsRequiresStub(Unknown Source)
    at com.sun.corba.se.impl.logging.ORBUtilSystemException.getTypeIdsRequiresStub(Unknown Source)
    at com.sun.corba.se.spi.presentation.rmi.StubAdapter.getTypeIds(Unknown Source)
    at com.sun.corba.se.impl.oa.toa.TOAImpl.connect(Unknown Source)
    ... 2 more
Can't rebind NameComponent to StockServer: 
org.omg.CORBA.BAD_PARAM:   vmcid: SUN  minor code: 206  completed: No
    at com.sun.corba.se.impl.logging.ORBUtilSystemException.localObjectNotAllowed(Unknown Source)
    at com.sun.corba.se.impl.logging.ORBUtilSystemException.localObjectNotAllowed(Unknown Source)
    at com.sun.corba.se.impl.orbutil.ORBUtility.getIOR(Unknown Source)
    at com.sun.corba.se.impl.orbutil.ORBUtility.connectAndGetIOR(Unknown Source)
    at com.sun.corba.se.impl.encoding.CDROutputStream_1_0.write_Object(Unknown Source)
    at com.sun.corba.se.impl.encoding.CDROutputStream.write_Object(Unknown Source)
    at org.omg.CORBA.ObjectHelper.write(Unknown Source)
    at org.omg.CosNaming._NamingContextExtStub.rebind(Unknown Source)
    at StockMarket.StockServerImpl.main(StockServerImpl.java:151)

如果你对这篇内容有疑问，欢迎到本站社区发帖提问 参与讨论，获取更多帮助，或者扫码二维码加入 Web 技术交流群。

扫码二维码加入Web技术交流群

发布评论

需要 登录 才能够评论， 你可以免费 注册 一个本站的账号。

评论（1）

探春 2024-10-02 11:11:23

我从来没有弄清楚“为什么”，而是通过将我的代码与此

这是服务器的工作代码：

// StockServerImpl.java

package StockMarket;

import java.util.Vector;

import org.omg.CORBA.*;
import org.omg.CORBA.Object;
import org.omg.CosNaming.NameComponent;
import org.omg.CosNaming.NamingContextExt;
import org.omg.CosNaming.NamingContextExtHelper;
import org.omg.CosNaming.NamingContextPackage.CannotProceed;
import org.omg.CosNaming.NamingContextPackage.NotFound;
import org.omg.PortableServer.*;
import org.omg.PortableServer.POAPackage.ServantNotActive;
import org.omg.PortableServer.POAPackage.WrongPolicy;


// StockServerImpl implements the StockServer IDL interface
public class StockServerImpl
    extends StockServerPOA
    //extends _StockServerImplBase 
    implements StockServer 
{
    /**
     * 
     */
    private static final long serialVersionUID = 1L;
    public static final String SERVICENAME = "StockServer";
    // Stock symbols and their respective values.
    private Vector<String> myStockSymbols;
    private Vector<Float> myStockValues;

    @SuppressWarnings("unused")
    private ORB orb;
    public void setORB(ORB orb_val) {orb = orb_val; }

    // Characters from which StockSymbol names are built.
    private static char ourCharacters[] = 
    { 
                         'A', 'B', 'C', 'D', 'E', 'F', 'G', 'H', 'I',
                         'J', 'K', 'L', 'M', 'N', 'O', 'P', 'Q', 'R',
                         'S', 'T', 'U', 'V', 'W', 'X', 'Y', 'Z' 
    };

    // Path name for StockServer objects.
    private static String ourPathName = "StockServer";

    // Create a new StockServerImpl.
    public StockServerImpl()
    {
        myStockSymbols = new Vector<String>();
        myStockValues = new Vector<Float>();

        // Initialize the symbols and values with some random values.
        for (int i=0; i<10; i++)
        {
            // Generate a string of four random characters.
            StringBuffer stockSymbol = new StringBuffer("    ");
            for (int j=0; j<4; j++)
                { stockSymbol.setCharAt(j, ourCharacters[(int) (Math.random() * 26f)]); }

            myStockSymbols.addElement(stockSymbol.toString());

            // Give the stock a value between 0 and 100.  In this example,
            // the stock will retain this value for the duration of the
            // application.
            myStockValues.addElement(new Float(Math.random() * 100f));
        }

        // Print out the stock symbols generated above.
        System.out.println("Generated stock symbols:");
        for (int i=0; i<10; i++)
            { 
                System.out.println( 
                                    " " + myStockSymbols.elementAt(i) 
                                  + " " + myStockValues.elementAt(i)
                );
            } 
        System.out.println();
    }

    // Return the current value for the given StockSymbol.
    @Override
    public float getStockValue(String symbol) throws InvalidStockSymbolException 
    {
        System.out.println("Getting stock value for symbol: " + symbol);
        // Try to find the given symbol.
        int stockIndex = myStockSymbols.indexOf(symbol);
        if (stockIndex != -1)
        {
            // Symbol found; return its value.
            return (myStockValues.elementAt(stockIndex).floatValue());
        }
        else
        {
            // Symbol was not found.
            throw new InvalidStockSymbolException();
        }
    }

    // Return a sequence of all StockSymbols known by this StockServer.
    @Override
    public String[] getStockSymbols() 
    {
        System.out.println("Getting stock symbols...");
        String[] symbols = new String[myStockSymbols.size()];
        myStockSymbols.copyInto(symbols);
        return symbols;
    }

    /**
     * @param ourPathName the ourPathName to set
     */
    public static void setOurPathName(String ourPathName) {
        StockServerImpl.ourPathName = ourPathName;
    }

    /**
     * @return the ourPathName
     */
    public static String getOurPathName() {
        return ourPathName;
    }

    // Create and initialize a StockServer object.
    public static void main (String args[])
    {
        NameComponent path[] = null;
        NamingContextExt ncRef = null;
        org.omg.CORBA.Object objRef = null;
        org.omg.CORBA.Object ref = null;
        StockServer href = null;
        StockServerImpl stockServerImpl = null;

        ORB orb = StockServerORBHelper.getORB(args);
        POA rootpoa = StockServerPOAHelper.getRoot(orb);

        try { stockServerImpl = new StockServerImpl(); } // Create a StockServerImpl object and register it with the ORB.
        catch (Exception ex) { System.err.println("Can't create StockServer: " + ex.getMessage()); }

        try { stockServerImpl.setORB(orb); }
        catch (Exception ex) { System.err.println("Can't set ORB on StockServer: " + ex.getMessage()); }

/*      
        try { orb.connect(stockServerImpl); }
        catch (Exception ex) { System.err.println("Can't connect ORB to StockServer: " + ex.getMessage()); ex.printStackTrace(); }
*/

        // get object reference from the servant

        try { ref = rootpoa.servant_to_reference(stockServerImpl); } 
        catch (ServantNotActive ex) { System.err.println("Can't assign servant to reference, Servant Not Active: " + ex.getMessage()); ex.printStackTrace(); } // TODO Auto-generated catch block
        catch (WrongPolicy ex) { System.err.println("Can't assign servant to reference, Wrong Policy: " + ex.getMessage()); ex.printStackTrace(); } // TODO Auto-generated catch block

        try { href = StockServerHelper.narrow(ref); }
        catch (Exception ex) { System.err.println("Can't narrow StockServer: " + ex.getMessage()); ex.printStackTrace(); }

        try { objRef = orb.resolve_initial_references("NameService"); } // Get the root naming context.
        catch (Exception ex) { System.err.println("Can't resolve NameServeice: " + ex.getMessage());  ex.printStackTrace();}

        try { ncRef = NamingContextExtHelper.narrow(objRef); }
        catch (Exception ex) { System.err.println("Can't narrow NamingContextExt: " + ex.getMessage()); }

        //NameComponent path[] = { nameComponent };
        try { path = ncRef.to_name(SERVICENAME); } 
        catch (org.omg.CosNaming.NamingContextPackage.InvalidName ex) { System.err.println("Can't name path: " + ex.getMessage()); } // TODO Auto-generated catch block

        try { ncRef.rebind(path, href); } 
        catch (NotFound ex) { System.err.println("Can't rebind ncRef, not Found: " + ex.getMessage()); } // TODO Auto-generated catch block
        catch (CannotProceed ex) { System.err.println("Can't rebind ncRef, cannot proceed: " + ex.getMessage()); } // TODO Auto-generated catch block
        catch (org.omg.CosNaming.NamingContextPackage.InvalidName ex) { System.err.println("Can't rebind ncRef, invalid name: " + ex.getMessage()); } // TODO Auto-generated catch block

/*      
        try { namingContext.rebind(path, stockServerImpl); }
        catch (Exception ex) { System.err.println("Can't rebind NameComponent to StockServer: " + ex.getMessage()); ex.printStackTrace(); }
*/

        System.out.println("StockServer ready and waiting...");

        // wait for invocations from clients
        orb.run();

        // Wait for invocations from clients.
        java.lang.Object waitOnMe = new java.lang.Object();
        synchronized(waitOnMe) 
        { 
            try { waitOnMe.wait(); } 
            catch (InterruptedException ex) 
            {
                System.err.println("Can't wait: " + ex.getMessage());
                ex.printStackTrace();
            } 
        }

        System.out.println("StockServer Exiting...");
    }

    @Override
    public Request _create_request(Context arg0, String arg1, NVList arg2,
            NamedValue arg3) {
        // TODO Auto-generated method stub
        return null;
    }

    @Override
    public Request _create_request(Context arg0, String arg1, NVList arg2,
            NamedValue arg3, ExceptionList arg4, ContextList arg5) {
        // TODO Auto-generated method stub
        return null;
    }

    @Override
    public Object _duplicate() {
        // TODO Auto-generated method stub
        return null;
    }

    @Override
    public DomainManager[] _get_domain_managers() {
        // TODO Auto-generated method stub
        return null;
    }

    @Override
    public Policy _get_policy(int arg0) {
        // TODO Auto-generated method stub
        return null;
    }

    @Override
    public int _hash(int arg0) {
        // TODO Auto-generated method stub
        return 0;
    }

    @Override
    public boolean _is_equivalent(Object arg0) {
        // TODO Auto-generated method stub
        return false;
    }

    @Override
    public void _release() {
        // TODO Auto-generated method stub

    }

    @Override
    public Request _request(String arg0) {
        // TODO Auto-generated method stub
        return null;
    }

    @Override
    public Object _set_policy_override(Policy[] arg0, SetOverrideType arg1) {
        // TODO Auto-generated method stub
        return null;
    }


} // interface StockServer

要启动服务器，现在需要使用参数，即：

start java StockMarket/StockServerImpl -ORBInitialPort 1050 -ORBInitialHost localhost

I never figured out "why", but by comparing my code to this Hello World, I was able to create a work-around. I think the main obstacle was the use of NamingContextHelper instead of NamingContextExtHelper.

Here is working code for the server:

// StockServerImpl.java

package StockMarket;

import java.util.Vector;

import org.omg.CORBA.*;
import org.omg.CORBA.Object;
import org.omg.CosNaming.NameComponent;
import org.omg.CosNaming.NamingContextExt;
import org.omg.CosNaming.NamingContextExtHelper;
import org.omg.CosNaming.NamingContextPackage.CannotProceed;
import org.omg.CosNaming.NamingContextPackage.NotFound;
import org.omg.PortableServer.*;
import org.omg.PortableServer.POAPackage.ServantNotActive;
import org.omg.PortableServer.POAPackage.WrongPolicy;


// StockServerImpl implements the StockServer IDL interface
public class StockServerImpl
    extends StockServerPOA
    //extends _StockServerImplBase 
    implements StockServer 
{
    /**
     * 
     */
    private static final long serialVersionUID = 1L;
    public static final String SERVICENAME = "StockServer";
    // Stock symbols and their respective values.
    private Vector<String> myStockSymbols;
    private Vector<Float> myStockValues;

    @SuppressWarnings("unused")
    private ORB orb;
    public void setORB(ORB orb_val) {orb = orb_val; }

    // Characters from which StockSymbol names are built.
    private static char ourCharacters[] = 
    { 
                         'A', 'B', 'C', 'D', 'E', 'F', 'G', 'H', 'I',
                         'J', 'K', 'L', 'M', 'N', 'O', 'P', 'Q', 'R',
                         'S', 'T', 'U', 'V', 'W', 'X', 'Y', 'Z' 
    };

    // Path name for StockServer objects.
    private static String ourPathName = "StockServer";

    // Create a new StockServerImpl.
    public StockServerImpl()
    {
        myStockSymbols = new Vector<String>();
        myStockValues = new Vector<Float>();

        // Initialize the symbols and values with some random values.
        for (int i=0; i<10; i++)
        {
            // Generate a string of four random characters.
            StringBuffer stockSymbol = new StringBuffer("    ");
            for (int j=0; j<4; j++)
                { stockSymbol.setCharAt(j, ourCharacters[(int) (Math.random() * 26f)]); }

            myStockSymbols.addElement(stockSymbol.toString());

            // Give the stock a value between 0 and 100.  In this example,
            // the stock will retain this value for the duration of the
            // application.
            myStockValues.addElement(new Float(Math.random() * 100f));
        }

        // Print out the stock symbols generated above.
        System.out.println("Generated stock symbols:");
        for (int i=0; i<10; i++)
            { 
                System.out.println( 
                                    " " + myStockSymbols.elementAt(i) 
                                  + " " + myStockValues.elementAt(i)
                );
            } 
        System.out.println();
    }

    // Return the current value for the given StockSymbol.
    @Override
    public float getStockValue(String symbol) throws InvalidStockSymbolException 
    {
        System.out.println("Getting stock value for symbol: " + symbol);
        // Try to find the given symbol.
        int stockIndex = myStockSymbols.indexOf(symbol);
        if (stockIndex != -1)
        {
            // Symbol found; return its value.
            return (myStockValues.elementAt(stockIndex).floatValue());
        }
        else
        {
            // Symbol was not found.
            throw new InvalidStockSymbolException();
        }
    }

    // Return a sequence of all StockSymbols known by this StockServer.
    @Override
    public String[] getStockSymbols() 
    {
        System.out.println("Getting stock symbols...");
        String[] symbols = new String[myStockSymbols.size()];
        myStockSymbols.copyInto(symbols);
        return symbols;
    }

    /**
     * @param ourPathName the ourPathName to set
     */
    public static void setOurPathName(String ourPathName) {
        StockServerImpl.ourPathName = ourPathName;
    }

    /**
     * @return the ourPathName
     */
    public static String getOurPathName() {
        return ourPathName;
    }

    // Create and initialize a StockServer object.
    public static void main (String args[])
    {
        NameComponent path[] = null;
        NamingContextExt ncRef = null;
        org.omg.CORBA.Object objRef = null;
        org.omg.CORBA.Object ref = null;
        StockServer href = null;
        StockServerImpl stockServerImpl = null;

        ORB orb = StockServerORBHelper.getORB(args);
        POA rootpoa = StockServerPOAHelper.getRoot(orb);

        try { stockServerImpl = new StockServerImpl(); } // Create a StockServerImpl object and register it with the ORB.
        catch (Exception ex) { System.err.println("Can't create StockServer: " + ex.getMessage()); }

        try { stockServerImpl.setORB(orb); }
        catch (Exception ex) { System.err.println("Can't set ORB on StockServer: " + ex.getMessage()); }

/*      
        try { orb.connect(stockServerImpl); }
        catch (Exception ex) { System.err.println("Can't connect ORB to StockServer: " + ex.getMessage()); ex.printStackTrace(); }
*/

        // get object reference from the servant

        try { ref = rootpoa.servant_to_reference(stockServerImpl); } 
        catch (ServantNotActive ex) { System.err.println("Can't assign servant to reference, Servant Not Active: " + ex.getMessage()); ex.printStackTrace(); } // TODO Auto-generated catch block
        catch (WrongPolicy ex) { System.err.println("Can't assign servant to reference, Wrong Policy: " + ex.getMessage()); ex.printStackTrace(); } // TODO Auto-generated catch block

        try { href = StockServerHelper.narrow(ref); }
        catch (Exception ex) { System.err.println("Can't narrow StockServer: " + ex.getMessage()); ex.printStackTrace(); }

        try { objRef = orb.resolve_initial_references("NameService"); } // Get the root naming context.
        catch (Exception ex) { System.err.println("Can't resolve NameServeice: " + ex.getMessage());  ex.printStackTrace();}

        try { ncRef = NamingContextExtHelper.narrow(objRef); }
        catch (Exception ex) { System.err.println("Can't narrow NamingContextExt: " + ex.getMessage()); }

        //NameComponent path[] = { nameComponent };
        try { path = ncRef.to_name(SERVICENAME); } 
        catch (org.omg.CosNaming.NamingContextPackage.InvalidName ex) { System.err.println("Can't name path: " + ex.getMessage()); } // TODO Auto-generated catch block

        try { ncRef.rebind(path, href); } 
        catch (NotFound ex) { System.err.println("Can't rebind ncRef, not Found: " + ex.getMessage()); } // TODO Auto-generated catch block
        catch (CannotProceed ex) { System.err.println("Can't rebind ncRef, cannot proceed: " + ex.getMessage()); } // TODO Auto-generated catch block
        catch (org.omg.CosNaming.NamingContextPackage.InvalidName ex) { System.err.println("Can't rebind ncRef, invalid name: " + ex.getMessage()); } // TODO Auto-generated catch block

/*      
        try { namingContext.rebind(path, stockServerImpl); }
        catch (Exception ex) { System.err.println("Can't rebind NameComponent to StockServer: " + ex.getMessage()); ex.printStackTrace(); }
*/

        System.out.println("StockServer ready and waiting...");

        // wait for invocations from clients
        orb.run();

        // Wait for invocations from clients.
        java.lang.Object waitOnMe = new java.lang.Object();
        synchronized(waitOnMe) 
        { 
            try { waitOnMe.wait(); } 
            catch (InterruptedException ex) 
            {
                System.err.println("Can't wait: " + ex.getMessage());
                ex.printStackTrace();
            } 
        }

        System.out.println("StockServer Exiting...");
    }

    @Override
    public Request _create_request(Context arg0, String arg1, NVList arg2,
            NamedValue arg3) {
        // TODO Auto-generated method stub
        return null;
    }

    @Override
    public Request _create_request(Context arg0, String arg1, NVList arg2,
            NamedValue arg3, ExceptionList arg4, ContextList arg5) {
        // TODO Auto-generated method stub
        return null;
    }

    @Override
    public Object _duplicate() {
        // TODO Auto-generated method stub
        return null;
    }

    @Override
    public DomainManager[] _get_domain_managers() {
        // TODO Auto-generated method stub
        return null;
    }

    @Override
    public Policy _get_policy(int arg0) {
        // TODO Auto-generated method stub
        return null;
    }

    @Override
    public int _hash(int arg0) {
        // TODO Auto-generated method stub
        return 0;
    }

    @Override
    public boolean _is_equivalent(Object arg0) {
        // TODO Auto-generated method stub
        return false;
    }

    @Override
    public void _release() {
        // TODO Auto-generated method stub

    }

    @Override
    public Request _request(String arg0) {
        // TODO Auto-generated method stub
        return null;
    }

    @Override
    public Object _set_policy_override(Policy[] arg0, SetOverrideType arg1) {
        // TODO Auto-generated method stub
        return null;
    }


} // interface StockServer

To launch the server, it is now necessary to use arguments, ie:

start java StockMarket/StockServerImpl -ORBInitialPort 1050 -ORBInitialHost localhost
回复 原文
~没有更多了~

关于作者

霓裳挽歌倾城醉

暂无简介

0 文章
0 评论
23 人气
发私信

相关话题

更多

热门标签

操作系统 程序设计 IT运维 Linux系统管理 JavaScript 服务器应用 solaris C/C++ PHP Shell BSD Vue.js aix Oracle Python HTML 系统管理 HTML5 CSS 前端
更多

推荐作者

烙印

文章 0 评论 0

singlesman

文章 0 评论 0

给自己一个微笑

文章 0 评论 0

独孤求败

文章 0 评论 0

晨钟暮鼓

文章 0 评论 0

我是自愿种绣球花的

文章 0 评论 0

更多

友情链接

文江博客
    我们使用 Cookies 和其他技术来定制您的体验包括您的登录状态等。通过阅读我们的 隐私政策 了解更多相关信息。 单击 接受 或继续使用网站，即表示您同意使用 Cookies 和您的相关数据。
    原文