Мне поручено написать инструмент управления распределенными событиями, где каждый клиент, будь то клиент Ruby, C # или Java, синхронизирует все изменения со списком зарегистрированных клиентов.Я должен использовать XML-RPC для достижения цели.Моя команда и я написали XML-RPC клиента и сервера на каждом языке и предоставим соответствующий исходный код ниже.Если вам требуется больше кода, сообщите мне.
Проблема в том, что я могу заставить Java и C # общаться друг с другом.Ruby может общаться с другими, но C # (и, возможно, Java, еще не тестировал) имеют проблемы с сервером Ruby.Я думаю, что проблема с конечной точкой.Сначала позвольте мне дать вам код.При чтении следует помнить, что код на самом деле написан командой, и соглашения об именах немного отличаются:
C # клиент
Uri _address = new Uri("http://" + _s + ":8000/xmlrpc/EventManagerService");
ChannelFactory<IEventManagerWCF_XML_RPC> _factory = new ChannelFactory<IEventManagerWCF_XML_RPC>(new WebHttpBinding(WebHttpSecurityMode.None), new EndpointAddress(_address));
_factory.Endpoint.Behaviors.Add(new XmlRpcEndpointBehavior());
IEventManagerWCF_XML_RPC _proxy = _factory.CreateChannel();
_proxy не будет удерживатьсяклиент для данного URI.Они хранятся в словаре и используются, когда возникает необходимость в синхронизации событий.Одна такая синхронизация может произойти в случае модификации;
foreach(IEventManagerWCF_XML_RPC proxy in this.peers.Values)
proxy.modify(_id, _field, _newValue);
Вот выдержка из интерфейса IEventManagerWCF_XML_RPC;
[OperationContract(Action = "EventManagerService.modify")]
bool modify(int id, string field, string newValue);
C # XML RPC service
Uri _baseAddress = new Uri("http://localhost:8000/xmlrpc");
_eventManagerHost = new ServiceHost(typeof(EventManagerService), _baseAddress);
try
{
ServiceEndpoint epXmlRpc = _eventManagerHost.AddServiceEndpoint(typeof(IEventManagerWCF_XML_RPC), new WebHttpBinding(WebHttpSecurityMode.None), "EventManagerService");
epXmlRpc.Behaviors.Add(new XmlRpcEndpointBehavior());
ServiceMetadataBehavior smb = new ServiceMetadataBehavior();
smb.HttpGetEnabled = true;
_eventManagerHost.Description.Behaviors.Add(smb);
_eventManagerHost.Open();
}
catch (CommunicationException ce)
{
Console.WriteLine("An exception occurred: {0}", ce.Message);
_eventManagerHost.Abort();
}
Ничего особенного здесь, я думаю.Давайте перейдем к коду Java!
Клиент Java
XmlRpcClientConfigImpl config = new XmlRpcClientConfigImpl();
try {
config.setServerURL(new URL("http://"+ip+":8000/xmlrpc/EventManagerService"));
}
catch (MalformedURLException e) {
e.printStackTrace();
}
config.setEnabledForExtensions(true);
config.setConnectionTimeout(60 * 1000);
config.setReplyTimeout(60 * 1000);
XmlRpcClient client = new XmlRpcClient();
client.setTransportFactory(new XmlRpcCommonsTransportFactory(client));
client.setConfig(config);
xmlRpcPeers.put(ip, client);
xmlRpcPeers теперь содержит различные клиенты.Они вызываются следующим образом:
for(XmlRpcClient peer : this.xmlRpcPeers.values())
{
try {
peer.execute("EventManagerService.modify", params);
} catch (Exception e) {
e.printStackTrace();
}
}
Java-сервер имеет свой собственный класс и создается с помощью простого вызова new;
public class Server extends Thread{
/**
* Server port
*/
private static final int port = 8000;
/**
* Starts the XML-RPC server
*/
public void run(){
WebServer webServer = new WebServer(port);
XmlRpcServer xmlRpcServer = webServer.getXmlRpcServer();
PropertyHandlerMapping phm = new PropertyHandlerMapping();
try
{
phm.addHandler("EventManagerService", lu.uni.binfo.ds.EventManager_Java.EventManagerService.class);
}
catch (XmlRpcException e1)
{
e1.printStackTrace();
}
xmlRpcServer.setHandlerMapping(phm);
XmlRpcServerConfigImpl serverConfig = (XmlRpcServerConfigImpl) xmlRpcServer.getConfig();
serverConfig.setEnabledForExtensions(true);
serverConfig.setContentLengthOptional(false);
try
{
webServer.start();
}
catch (IOException e)
{
e.printStackTrace();
}
}
}
Дотеперь все вроде нормально работает.Добавление Ruby в смесь - это то, что доставляет больше всего хлопот.Вот соответствующий код:
Клиент Ruby Клиенты Ruby также хранятся в словаре.Он заполняется следующим образом:
@devices_XMLRPC[key] = EventManagerClient_XMLRPC.new(tokens[0]).device
Код класса:
class EventManagerClient_XMLRPC
@uri
@device
attr_accessor :uri, :device
def initialize(uri)
@uri = uri
@device = XMLRPC::Client.new2(
uri="http://" << @uri.to_s << ":8000/xmlrpc/EventManagerService", proxy=nil, timeout=30)
end
end
Вызов синхронизации для изменений выглядит следующим образом:
@devices_XMLRPC.each_value { |client| client.call("EventManagerService.modify", tokens[0], field, value) }
Ruby Server
server = XMLRPC::Server.new(8000, "127.0.0.1")
server.add_handler("xmlrpc/EventManagerService", EventManagerService.instance)
puts "Server ready!"
server.serve
Класс EventManagerService:
class EventManagerService
include Singleton
@manager
def initialize()
@manager = EventManager.instance
end
def modify(id, field, newValue)
puts "modify called"
@manager.modify([id, field, newValue], 1)
end
end
EventManager - класс, в котором находится вся логика.
Ошибкапри попытке установить связь между C # и Ruby EndPointNotFoundException, который гласит:
There was no endpoint listening at http://ip:8000/xmlrpc/EventManagerService that could accept the message.[...]
Я попытался поиграться с объявлением конечной точки, но, похоже, не смог заставить его работать.Документация по Ruby тоже не помогает.Мне нужна помощь!