我的任务是编写一个分布式事件管理工具,其中每个客户端(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 服务
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 Server有它自己的类,并通过一个简单的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) }
红宝石服务器
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 文档也无济于事。我需要帮助!