郑州图书大厦:eveMontior

来源:百度文库 编辑:九乡新闻网 时间:2024/04/28 17:38:35

config.icebox IceBox.ServiceManager.Endpoints=tcp -p 9998IceBox.Service.IceStorm=IceStormService,34:createIceStorm --Ice.Config=config.service
config.eveMoniGlobalMsgAPI.Subscriber.Endpoints=tcp:udpTopicManager.Proxy=eveMonitor/TopicManager:default -p 10000
config.serviceIceStorm.InstanceName=eveMonitorIceStorm.TopicManager.Endpoints=default -p 10000IceStorm.Publish.Endpoints=tcp -p 10001:udp -p 10001....
config.pub TopicManager.Proxy=eveMonitor/TopicManager:default -p 10000
config.subGlobalMsgAPI.Subscriber.Endpoints=tcp:udpTopicManager.Proxy=eveMonitor/TopicManager:default -p 10000
(以上的端口信息在用icegrid之后,均要去掉,否则会出现connection refused的错误信息)
首先运行icebox --Ice.Config=config.icebox运行 eveMonitor 创建GlobalTopic并订阅这个Topic 创建Heartbeat消息并订阅运行 Subscriber 订阅GlobalTopic 然后发布Heartbeat消息Subscriber2 是第二个可以用于测试的订阅者,里面多了一个被注释掉的用于测试全局发送控制消息的pub的代码块
eveMonitor.cpp 创建了一个GlobalMsgAPI.Subscriber adapter(这个端口应该自己提供的吧?)创建了GlobalTopic并订阅,加入了上面这个adapter,另外又创建了Heartbeat并订阅,然后开始监控运行。配置在config.eveMoni里面
config.eveMoniGlobalMsgAPI.Subscriber.Endpoints=tcp:udp ??TopicManager.Proxy=eveMonitor/TopicManager:default -p 10000
config.icebox
IceBox.ServiceManager.Endpoints=tcp -p 9998 仅仅用于与IceBox ServiceManager object交流,IceStorm服务有自己的端口在config.serviceIceBox.Service.IceStorm=IceStormService,34:createIceStorm --Ice.Config=config.service

eveMonitor.cpp    Ice::ObjectAdapterPtr adapter = communicator()->createObjectAdapter("GlobalMsgAPI.Subscriber");        Ice::ObjectPtr object = new GlobalMsgAPII;    //以下暂时没有判断返回值    createTopic("GlobalTopic", adapter);    subscribe("GlobalTopic", object, adapter);
    object = new HeartbeatAPII;    createTopic("Heartbeat", adapter);    subscribe("Heartbeat", object, adapter);        adapter->activate();       shutdownOnInterrupt();        monitor();        communicator()->waitForShutdown();
改为集群版本的时候: 这个端口号,是否创建的时候都不用指定?   config.icebox 就没有用了