.net remoting和wcf自托管——一个bug引起的警示

1、解决问题,须要深刻,并从细节入手,多从代码找缘由,不能认为代码是死的,不会出错:c++

以前代码都运行良好,忽然某一天,在我电脑上出问题了。出了问题,那就应该找出缘由。其实这个问题,自己并不难,好歹给你报出了个错:服务器

获取Word远程代理服务失败:没法加载类型“clr:NoteFirst.KMS.Clients.RomoteInterface.IOfficeService, NoteFirst.KMS.Clients.RomoteInterface”。,
Server stack trace: 
   在 System.Runtime.Remoting.Messaging.MethodCall.ResolveMethod(Boolean bThrowIfNotResolved)
   在 System.Runtime.Remoting.Messaging.MethodCall.HeaderHandler(Header[] h)
   在 System.Runtime.Serialization.Formatters.Soap.ObjectReader.ParseObject(ParseRecord pr)
   在 System.Runtime.Serialization.Formatters.Soap.SoapHandler.StartChildren()
   在 System.Runtime.Serialization.Formatters.Soap.SoapParser.ParseXml()
   在 System.Runtime.Serialization.Formatters.Soap.SoapParser.Run()
   在 System.Runtime.Serialization.Formatters.Soap.ObjectReader.Deserialize(HeaderHandler handler, ISerParser serParser)
   在 System.Runtime.Serialization.Formatters.Soap.SoapFormatter.Deserialize(Stream serializationStream, HeaderHandler handler)
   在 System.Runtime.Remoting.Channels.CoreChannel.DeserializeSoapRequestMessage(Stream inputStream, Header[] h, Boolean bStrictBinding, TypeFilterLevel securityLevel)
   在 System.Runtime.Remoting.Channels.SoapServerFormatterSink.ProcessMessage(IServerChannelSinkStack sinkStack, IMessage requestMsg, ITransportHeaders requestHeaders, Stream requestStream, IMessage& responseMsg,
ITransportHeaders& responseHeaders, Stream& responseStream)

net remoting在调用定义的接口时报错,没法加载类型,这错误是个什么样的错误,怎么就不能加载了,以前都好好的。为了解决这个问题,我花了一天多的时间。从系统运行环境,到office从新安装,折腾了个遍,就差装系统了。都说出了问题,从内部找缘由,但是同事机器上的代码运行良好,咱们的代码绝对一致。因而,我把目光就聚焦到外部环境上了。不过话说回来,外部环境也是有点问题的,好比安装了多个版本的office。在安装和卸载的频繁操做之下,很难知道注册表会不会出问题。socket

到了次日,我就去改改代码,试着用另一种方法解决问题。结果改着改着,就发现了代码原来是有bug的。前辈的代码,看似高深,调用了c++的不少方法。tcp

TcpChannel tcpChannel = new TcpChannel(9998);
ChannelServices.RegisterChannel(tcpChannel, false);
RemotingConfiguration.RegisterWellKnownServiceType(typeof(OfficeServiceImplement), CHANNEL_NAME, WellKnownObjectMode.SingleCall);

EventLog.WriteEntry("NoteFirst", "注册tcp remote服务成功");

以前remoting采用的是http通道,我给改为tcp通道,结果问题就解决了。我就想,仅仅是通道不一样,就会解决问题吗,因此想着http通道确定是能够的。ide

  channel = new HttpServerChannel(CHANNEL_NAME, GetEnablePort(), Provider);
  RemotingConfiguration.RegisterWellKnownServiceType(typeof(OfficeServiceImplement), OBJECT_URI, WellKnownObjectMode.Singleton);

看下GetEnablePort的定义:url

        private static int GetEnablePort()
        {
            Socket socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
            int result = 4211;
            while (true)
            {
                try
                {
                    socket.Bind(new IPEndPoint(IPAddress.Any, result));

                    socket.Listen(100);

                    socket.Close();

                    ShareDataRW.OfficeAddinServicesPort = result;

                    break;
                }
                catch
                {
                    ++result;
                }
            }

            return result;
        }

动态获取了端口,并有赋值操做:ShareDataRW.OfficeAddinServicesPort = result;spa

 service = Activator.GetObject(typeof(IOfficeService), string.Format(OfficeService.ServiceUrl, ShareDataRW.OfficeAddinServicesPort)) as IOfficeService;

这个是客户端调用remoting的代码,看看 ShareDataRW.OfficeAddinServicesPort 端口是怎么获取的:.net

       public static int OfficeAddinServicesPort
        {
            get
            {
                return ReadShareDataStruct().OfficeAddinServicesPort;
            }
            set
            {
                ShareData sd = ReadShareDataStruct();
                sd.OfficeAddinServicesPort = value;
                WriteReadShareDataStruct(sd);
            }
        }

这里又引入了几个方法:代理

        //将数据从非托管内存块封送到新分配的指定类型的托管对象
private static ShareData ReadShareDataStruct() { return (ShareData)Marshal.PtrToStructure(ShareDataMemoryPoint, ShareDataType); }
//将数据从托管对象封送到非托管内存块中
private static void WriteReadShareDataStruct(ShareData data) { Marshal.StructureToPtr(data, ShareDataMemoryPoint, false); }

ShareData是个结构体:code

      [StructLayout(LayoutKind.Sequential)]
        private struct ShareData
        {
            public int ClientServicesPort;
            public int OfficeAddinServicesPort;
            public int WpsAddinServicesPort;
            public int MainWindowsHandle;
        }
Type ShareDataType = typeof(ShareData);  
ShareDataMemoryPoint由于牵扯到c++里面的东西,不过从字面上看,共享内存地址,我猜的。看了这么多代码,咱们大体理解,它是经过共享内存实现的端口存放,那为何服务器端存进去的端口和客户端取出来的端口就不同呢?这是个人疑惑点。为何以前的代码就没有发生过这样的事情,请不要
老提过去好很差,代码是动态运行的,内存当中的活动也是动态的。有一种可能性,就是发布服务的端口在代码执行到那句的时候已经定好了,并把它写到内存中了。等客户端再去拿的时候,在这以前值被动了手脚。至于谁修改了它,何时修改的,这将是一个秘密,等待探寻。


2、WCF实现:

在这漫长的解决问题当中,我无心间看到微软的建议:把.net remoting迁移到wcf中。微软给出了具体的迁移步骤,特别详细,因而我就改写了代码,用wcf去实现:

定义协议
   [ServiceContract]
    public interface IOfficeService
    {
        [OperationContract]
        void InsertTo(Bibliography[] bibliographies);

        [OperationContract]
        IntPtr GetActiveDocumentWindowHandle();

        [OperationContract]

        void Insert(string stream);

        /// <summary>
        /// 获取文档的初始化时间
        /// </summary>
        /// <returns></returns>
        [OperationContract]
        DateTime GetDateTimeOfActivedDocument();
    }  

注意:方法不能同名

怎么实现并不重要,想怎么实现就怎么实现,我只管定义接口,这是发布服务,自托管服务:

  NetTcpBinding binding = new NetTcpBinding();
  Uri baseAddress = new Uri("net.tcp://localhost:8099/wcfserver");

  ServiceHost serviceHost = new ServiceHost(typeof(OfficeServiceImplement), baseAddress);
  serviceHost.AddServiceEndpoint(typeof(IOfficeService), binding, baseAddress);
  serviceHost.Open();
         
  EventLog.WriteEntry("NoteFirst", string.Format("The WCF server is ready at {0}", baseAddress));

再来看看客户端的调用:

  NetTcpBinding binding = new NetTcpBinding();
  String url = "net.tcp://localhost:8099/wcfserver";
  EndpointAddress address = new EndpointAddress(url);
  ChannelFactory<IOfficeService> channelFactory = new ChannelFactory<IOfficeService>(binding, address);
  service = channelFactory.CreateChannel();

拿到service,即远程对象的代理,咱们就能够调用接口中的方法了。

注意:实际代码中,须要考虑通道的释放等问题。

相关文章
相关标签/搜索