至顶网›软件频道 ›[冷枫]Remoting的事件机制

[冷枫]Remoting的事件机制

扫一扫
分享文章到微信
扫一扫
关注官方公众号
至顶头条

Remoting的事件机制（带具体例子）

作者：冷枫来源：CSDN 2007年9月23日

关键字：

客户端为了简单一点，我去除了前面做测试的本地事件：

using System;
using System.Net;
using System.Collections;
using System.Text;
using System.Runtime.Remoting;
using System.Runtime.Remoting.Channels;
using System.Runtime.Remoting.Channels.Tcp;
using System.Runtime.Serialization.Formatters;

class MyClient
{
    private delegate int MyDelegate(int a,int b,int time,string ip);
    private static MyDelegate md;

    [STAThread]
    static void Main(string[] args)
    {
        DateTime dt=DateTime.Now;
        RemotingConfiguration.RegisterWellKnownClientType(typeof(RemoteObject.MyObject), "tcp://localhost:9999/RemoteObject.MyObject");
        BinaryServerFormatterSinkProvider serverProvider = new BinaryServerFormatterSinkProvider();
        BinaryClientFormatterSinkProvider clientProvider = new BinaryClientFormatterSinkProvider();
        serverProvider.TypeFilterLevel = TypeFilterLevel.Full;
        IDictionary props=new Hashtable();
        props["port"]=0;
        TcpChannel channel = new TcpChannel(props,clientProvider,serverProvider);
        ChannelServices.RegisterChannel(channel);
        RemoteObject.MyObject app=new RemoteObject.MyObject();
        app.MyEvent+=new RemoteObject.MyObject.MyEventHandler(MyEvent);
        md=new MyDelegate(app.ALongTimeMethod);
        AsyncCallback ac=new AsyncCallback(MyClient.CallBack);
        IPHostEntry ipHE=Dns.GetHostByName(Dns.GetHostName());
        IAsyncResult Iar=md.BeginInvoke(1,2,300,ipHE.AddressList[0].ToString(),ac,null);
        Method();
        Console.WriteLine("用了"+((TimeSpan)(DateTime.Now-dt)).TotalSeconds+"秒");
        ChannelServices.UnregisterChannel(channel);
        Console.ReadLine();
    }

    public static void CallBack(IAsyncResult Iar)
    {
        if(Iar.IsCompleted)
        {
            Console.WriteLine("结果是"+md.EndInvoke(Iar));
        }
    }

    public static void MyEvent(object sender,RemoteObject.MyEventArgs e)
    {
        Console.WriteLine("来自"+e.IP+"的异步方法完成了"+e.Rate*10+"%");
    }

    public static void Method()
    {
        Console.WriteLine("主线程方法开始");
        System.Threading.Thread.Sleep(5000);
        Console.WriteLine("主线程方法结束");
    }
}

代码看上去不错，可是debug启动后报错：

这就是我前面提到的问题，远程不可能有本地的程序集，也无法触发本地事件。解决办法就是加一个事件中间件，继承MarshalByRefObject：

public class EventClass:MarshalByRefObject
    {
        public void MyEvent(object sender,MyEventArgs e)
        {
            Console.WriteLine("来自"+e.IP+"的异步方法完成了"+e.Rate*10+"%");
        }
    }

然后来修改一下客户端：
把app.MyEvent+=new RemoteObject.MyObject.MyEventHandler(MyEvent);修改为

RemoteObject.EventClass ec=new RemoteObject.EventClass();
app.MyEvent+=new RemoteObject.MyObject.MyEventHandler(ec.MyEvent);

删除客户端的MyEvent静态方法。

运行一下程序：