XSocket.net.如何从不是控制器的对象向客户端发送消息

Question

我有一个启动服务器的类:

public class SocketServer
{
    private static IXSocketServerContainer server = null;

    public SocketServer()
    {
        server = XSockets.Plugin.Framework.Composable
                      .GetExport<IXSocketServerContainer>();
    }

    public bool StartServers()
    {
        try
        {
            server.StartServers();
            return true;
        } catch
        {
            return false;
        }
    }

这个类有一个方法:

public void SendEventMessageToAllClients(string message)
{
    XSockets.Core.XSocket.Helpers.XSocketHelper
        .SendToAll<MyController>(new MyController(), message, "events");
}

MyController我自己的控制器在哪里,它被实现,服务器可以找到它,这个方法工作.

现在我想用一种新方法扩展功能,允许我将事件发送到特定客户端:

    public void SendEventMessageToClient(string clientId, string message)
    {
        XSockets.Core.XSocket.Helpers.XSocketHelper
             .SendTo<MyController>(new MyController(), 
                                   p => p.ClientId == clientId, message, "events");
    }

这是正确的方法还是我做错了什么？

谢谢!

Answer 1

我不会推荐这种方法,我甚至没有测试过这种方法是否有效.

您每次只能创建一个新的控制器才能访问扩展方法.我猜测,因为你在启动服务器的类上有这个,你只用它作为发布者？

如果是这样,正确的方法是安装XSockets.Client包并使用客户端池发布消息:客户端池文档

客户端池示例

客户端池的好处是您不需要每次都创建一个实例.池将重用您与控制器的连接.使用客户端池(或真实客户端连接)将确保消息通过管道和所有拦截器(如果有).直接使用控制器实例永远不会到达管道,拦截器等.

//Get a pool client
ClientPool poolClient =
        XSockets.Client.ClientPool.GetInstance("ws://127.0.0.1:4502/MyController", "*");

向控制器发送消息的方法.

public void SendEventMessageToClient(Guid clientId, string message)
{        
    poolClient.Send(new {clientId, message}, "SendEventMessageToClient");
} 


public void SendEventMessageToAllClients(string message)
{
    poolClient.Send(message, "SendEventMessageToAllClients");    
}

控制器

public void SendEventMessageToClient(Guid clientId, string message)
{
    this.SendTo(p => p.ClientId == clientId, message, "SendEventMessageToClient");
} 


public void SendEventMessageToAllClients(string message)
{
    this.SendToAll(message, "SendEventMessageToAllClients");
}

控制器实例示例

如果您决定使用已完成的方式,则至少应在控制器的一个实例上创建以在服务器类中使用它.

重要提示:直接使用控制器实例永远不会到达管道,拦截器等.

//Be aware of the fact that this controller NEVER will have a connection.
//It can only send to others, it can never receive messages!
MyController c = new MyController();

//You should probably have a Guid here instead of string
//Also note that the client have to subscribe for "events" to get the message
public void SendEventMessageToClient(Guid clientId, string message)
{
    this.SendTo(p => p.ClientId == clientId, message, "SendEventMessageToClient");
} 


public void SendEventMessageToAllClients(string message)
{
    this.SendToAll(message, "SendEventMessageToAllClients");
}

因为我不知道你想要完成什么我不确定这是最好的方法,但上面的一个方法应该有效.

编辑:此外,在一个真正的应用程序中,您可能无法访问MyController类,因为它可能是在编译时未被引用的单独程序集中.那么你的方法甚至是不可能的,然后去的方法是客户端或客户端池

/ Uffe