为啥我的 CORBA 服务器没有绑定？
Posted
技术标签:
【中文标题】为啥我的 CORBA 服务器没有绑定？【英文标题】：Why isn't my CORBA server binding?为什么我的 CORBA 服务器没有绑定？ 【发布时间】：2010-09-30 20:22:36 【问题描述】：目前正在努力完成 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)
【问题讨论】：
【参考方案1】：我从来没有弄清楚“为什么”，但是通过将我的代码与Hello World 进行比较，我能够创建一个解决方法。我认为主要障碍是使用 NamingContextHelper 而不是 NamingContextExtHelper。
这是服务器的工作代码：
// 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
【讨论】：
以上是关于为啥我的 CORBA 服务器没有绑定？的主要内容，如果未能解决你的问题，请参考以下文章
为啥 Corba VisiBroker java 服务器应用程序向同一个客户端回复不同的 GIOP 消息？
Corba NamingContextExtStub.resolve
org.omg.CORBA.MARSHAL：Valuetype 没有实现 StreamableValue 或 CustomMarshal