編集履歴

質問編集履歴

2019/09/18 22:03

投稿

kaito_19950605

スコア4

title CHANGED Viewed

File without changes

body CHANGED Viewed

@@ -17,6 +17,10 @@
 WCFによるプロセス間のイベント通知が出来ない。
+下記のソースコードのようにすると、以下のようになってしまいます。
+1. 1つ目のプロセスでイベント登録(OnCallback)。
+2. 2つ目のプロセスでInvokeしようとすると、OnCallbackがnullになっていてInvokeされない。
 ### 該当のソースコード
 サービスの定義（IdataTransferService.cs）

「前提・実現したいこと」に追記しました。

2019/09/18 22:03

投稿

kaito_19950605

スコア4

title CHANGED Viewed

File without changes

body CHANGED Viewed

@@ -7,6 +7,10 @@
 やりたいことのイメージとして、以下の画像を参考にして下さい。
 ![イメージ説明](b1fcaceee54f9d08c89526427762a332.png)
+ClientとServiceの双方向通信のサンプルはネット上にたくさん転がっていますが、
+あるClientがイベントを叩くと、もう一方のClientにイベント通知がされる、
+というパターンが見つかりませんでした。
 参考としてサイトをご紹介頂ける場合は、英語のサイトでも構いません。
 ### 発生している問題・エラーメッセージ

イメージ画像を追加しました。

2019/09/18 12:08

投稿

kaito_19950605

スコア4

title CHANGED Viewed

File without changes

body CHANGED Viewed

@@ -4,6 +4,8 @@
 プロセス間でイベント通知を行い、データを転送したいのですが、双方向通信にしてもイベントが飛びません。
 WCFを利用したプロセス間のイベント通知によるデータ転送の実現方法を教えて頂きたいです。
+やりたいことのイメージとして、以下の画像を参考にして下さい。
+![イメージ説明](b1fcaceee54f9d08c89526427762a332.png)
 参考としてサイトをご紹介頂ける場合は、英語のサイトでも構いません。

コールバックインターフェースの実装方法を変更しました。

2019/09/18 12:05

投稿

kaito_19950605

スコア4

title CHANGED Viewed

File without changes

body CHANGED Viewed

@@ -3,10 +3,10 @@
 WCFを使用して、名前付きパイプによるプロセス間通信を行うプログラムを実装しています。
 プロセス間でイベント通知を行い、データを転送したいのですが、双方向通信にしてもイベントが飛びません。
 WCFを利用したプロセス間のイベント通知によるデータ転送の実現方法を教えて頂きたいです。
-英語のサイトでも構いません。
+参考としてサイトをご紹介頂ける場合は、英語のサイトでも構いません。
 ### 発生している問題・エラーメッセージ
 WCFによるプロセス間のイベント通知が出来ない。
@@ -17,22 +17,26 @@
 ```C#
 namespace DataTransferWCFService
 {
-    // メモ: [リファクター] メニューの [名前の変更] コマンドを使用すると、コードと config ファイルの両方で同時にインターフェイス名 "IService1" を変更できます。
     [ServiceContract(CallbackContract = typeof(IGetResponseCallback))]
     public interface IDataTransferService
     {
-        // TODO: ここにサービス操作を追加します。
         [OperationContract(IsOneWay = true)]
         void Register(byte[] data);
         [OperationContract(IsOneWay = true)]
         void Clear();
         [OperationContract]
         byte[] GetResponse(UInt32 id, byte[] request);
+        /// <summary>
+        /// コールバック用
+        /// </summary>
+        /// <param name="id"></param>
+        /// <param name="message"></param>
+        [OperationContract(IsOneWay = true)]
+        void Send(UInt32 id, byte[] message);
     }
-    // サービス操作に複合型を追加するには、以下のサンプルに示すようにデータ コントラクトを使用します。
-    // プロジェクトに XSD ファイルを追加できます。プロジェクトのビルド後、そこで定義されたデータ型を、名前空間 "DataTransferWCFService.ContractType" で直接使用できます。
 }
 ```
@@ -52,13 +56,10 @@
 ```C#
 namespace DataTransferWCFService
 {
-    // メモ: [リファクター] メニューの [名前の変更] コマンドを使用すると、コードと config ファイルの両方で同時にクラス名 "Service1" を変更できます。
-    public class DataTransferService : IDataTransferService, IGetResponseCallback
+    public class DataTransferService : IDataTransferService
     {
         private static List<byte[]> dataList = new List<byte[]>();
-        public delegate void CallbackEventHandler(object sender, CommunicationEventArgs args);
-        public event CallbackEventHandler OnCallback;
         public void Clear()
         {
             dataList.Clear();
@@ -66,24 +67,29 @@
         public byte[] GetResponse(uint id, byte[] request)
         {
-            IGetResponseCallback callback = OperationContext.Current.GetCallbackChannel<IGetResponseCallback>();
             byte[] response = dataList.ElementAt((int)id)
                                        .Concat(request)
                                        .ToArray();
-            callback.GetResponseCallback(id, response);
             return response;
         }
-        public void GetResponseCallback(uint id, byte[] message)
+        public void Register(byte[] data)
         {
-            this.OnCallback?.Invoke(this, new CommunicationEventArgs(id, message));
+            dataList.Add(data);
         }
+        /// <summary>
+        /// コールバック用
+        /// </summary>
+        /// <param name="id"></param>
+        /// <param name="request"></param>
-        public void Register(byte[] data)
+        public void Send(uint id, byte[] message)
         {
+            IGetResponseCallback callback = OperationContext.Current.GetCallbackChannel<IGetResponseCallback>();
-            dataList.Add(data);
+            callback.GetResponseCallback(id, message);
         }
     }
 }
@@ -95,43 +101,72 @@
 {
     public class DataTransfer
     {
-        public DataTransferService DataTransferServiceInstance
+        public _DataTransfer instance = _DataTransfer.Instance;
+        /// <summary>
+        /// サービスの開始とチャンネルの実体化
+        /// </summary>
+        public void PreStart()
         {
-            get
-            {
-                return _DataTransfer.dtService;
+            this.instance.Start();
-            }
+            this.instance.Create();
         }
+        /// <summary>
+        /// チャンネルの実体化
+        /// </summary>
+        public void Create()
+        {
+            this.instance.Create();
+        }
         public void Register(byte[] data)
         {
-            _DataTransfer.Register(data);
+            this.instance.Register(data);
         }
         public void Clear()
         {
-            _DataTransfer.Clear();
+            this.instance.Clear();
         }
         public byte[] GetResponse(UInt32 id, byte[] request)
         {
-            return _DataTransfer.GetResponse(id, request);
+            return this.instance.GetResponse(id, request);
         }
     }
-    static class _DataTransfer
+    public class _DataTransfer : IGetResponseCallback
     {
-        private static string pipeName = @"net.pipe://sample";
+        private static string PIPE_NAME = @"net.pipe://sample";
-        private static ServiceHost host;
+        public ServiceHost host;
-        private static IDataTransferService client;
+        public IDataTransferService proxy;
-        static DuplexChannelFactory<IDataTransferService> factory;
+        public DuplexChannelFactory<IDataTransferService> factory;
+        public delegate void CallbackEventHandler(object sender, CommunicationEventArgs args);
+        public event CallbackEventHandler OnCallback;
+        //シングルトンパターン
-        public static DataTransferService dtService = new DataTransferService();
+        private static _DataTransfer instance = new _DataTransfer();
+        public static _DataTransfer Instance
+        {
+            get
+            {
+                return instance;
+            }
+        }
-        static _DataTransfer()
+        private _DataTransfer()
         {
-            host = new ServiceHost(typeof(IDataTransferService), new Uri(pipeName));
+        }
+        /// <summary>
+        /// サービスを開始
+        /// </summary>
+        public void Start()
+        {
+            Instance.host = new ServiceHost(typeof(IDataTransferService), new Uri(PIPE_NAME));
-            host.AddServiceEndpoint(typeof(IDataTransferService), new NetNamedPipeBinding(NetNamedPipeSecurityMode.None)
+            Instance.host.AddServiceEndpoint(typeof(IDataTransferService), new NetNamedPipeBinding(NetNamedPipeSecurityMode.None)
             {
                 ReceiveTimeout = TimeSpan.MaxValue
             }, string.Empty);
@@ -140,29 +175,29 @@
             {
                 host.Open();
             }
-            catch(Exception ex)
+            catch (Exception ex)
             {
                 Debug.WriteLine(ex.Message);
             }
-            Create();
         }
+        /// <summary>
+        /// チャンネルの実体化
+        /// </summary>
-        public static void Create()
+        public void Create()
         {
-            factory = new DuplexChannelFactory<IDataTransferService>(new InstanceContext(dtService), new NetNamedPipeBinding(NetNamedPipeSecurityMode.None)
+            Instance.factory = new DuplexChannelFactory<IDataTransferService>(new InstanceContext(Instance), new NetNamedPipeBinding(NetNamedPipeSecurityMode.None)
             {
                 MaxReceivedMessageSize = Int32.MaxValue
-            }, pipeName);
+            }, PIPE_NAME);
-            client = factory.CreateChannel();
+            Instance.proxy = Instance.factory.CreateChannel();
         }
-        public static void Clear()
+        public void Clear()
         {
             try
             {
-                client.Clear();
+                Instance.proxy.Clear();
             }
             catch(Exception ex)
             {
@@ -170,11 +205,11 @@
             }
         }
-        public static void Register(byte[] data)
+        public void Register(byte[] data)
         {
             try
             {
-                client.Register(data);
+                Instance.proxy.Register(data);
             }
             catch(Exception ex)
             {
@@ -182,11 +217,17 @@
             }
         }
-        public static byte[] GetResponse(UInt32 id, byte[] request)
+        public byte[] GetResponse(UInt32 id, byte[] request)
         {
             try
             {
-                return client.GetResponse(id, request);
+                Instance.proxy.Send(id, request);
+                byte[] response = Instance.proxy.GetResponse(id, request);
+                Instance.proxy.Send(id, response);
+                return response;
             }
             catch(Exception ex)
             {
@@ -195,58 +236,20 @@
                 return null;
             }
         }
+        /// <summary>
+        /// コールバックメソッドの実装
+        /// </summary>
+        /// <param name="id"></param>
+        /// <param name="message"></param>
+        public void GetResponseCallback(uint id, byte[] message)
+        {
+            Instance.OnCallback?.Invoke(this, new CommunicationEventArgs(id, message));
+        }
     }
 }
 ```
-WCFの設定ファイル（App.config）
-```XML
-<?xml version="1.0" encoding="utf-8" ?>
-<configuration>
-  <appSettings>
-    <add key="aspnet:UseTaskFriendlySynchronizationContext" value="true" />
-  </appSettings>
-  <system.web>
-    <compilation debug="true" />
-  </system.web>
-  <!-- サービス ライブラリ プロジェクトの展開時に、構成ファイルの内容をホストの app.config ファイルに追加する
-  必要があります。System.Configuration は、ライブラリの構成ファイルをサポートしていません。 -->
-  <system.serviceModel>
-    <services>
-      <service name="DataTransferWCFService.DataTransferService">
-        <endpoint address="" binding="wsDualHttpBinding" contract="DataTransferWCFService.IDataTransferService">
-          <identity>
-            <dns value="localhost" />
-          </identity>
-        </endpoint>
-        <endpoint address="mex" binding="mexHttpBinding" contract="IMetadataExchange" />
-        <host>
-          <baseAddresses>
-            <add baseAddress="http://localhost:8733/Design_Time_Addresses/DataTransferWCFService/Service1/" />
-          </baseAddresses>
-        </host>
-      </service>
-    </services>
-    <behaviors>
-      <serviceBehaviors>
-        <behavior>
-          <!-- メタデータ情報の開示を避けるには、
-          展開する前に下の値を false に設定します -->
-          <serviceMetadata httpGetEnabled="True" httpsGetEnabled="True"/>
-          <!-- デバッグ目的で障害発生時の例外の詳細を受け取るには、
-          下の値を true に設定します。例外情報の開示を避けるには、
-          展開する前に false に設定します -->
-          <serviceDebug includeExceptionDetailInFaults="False" />
-        </behavior>
-      </serviceBehaviors>
-    </behaviors>
-  </system.serviceModel>
-</configuration>
-```
 本体（Program.cs）
 ```C#
 namespace WCFIPC
@@ -261,6 +264,7 @@
             //2つ目のプロセスでは
             DataTransfer.DataTransfer dataTransfer = new DataTransfer.DataTransfer();
+            dataTransfer.Create();
             var response = dataTransfer.GetResponse(0xFF, new byte[] { 0x78, 0x90 });
         }
     }
@@ -271,13 +275,14 @@
         public void Register(byte[] data)
         {
+            this.service.PreStart();
             this.service.Register(data);
-            //ここでプロセス間のイベントを購読したい
+            //ここでイベントの購読をしたい
-            this.service.DataTransferServiceInstance.OnCallback += DataTransferServiceInstance_OnCallback;
+            this.service.instance.OnCallback += Instance_OnCallback;
         }
-        private void DataTransferServiceInstance_OnCallback(object sender, DataTransferWCFService.CommunicationEventArgs args)
+        private void Instance_OnCallback(object sender, DataTransferWCFService.CommunicationEventArgs args)
         {
             Console.Write(args.Message);
         }
@@ -292,8 +297,24 @@
 ### 試したこと
+・上記実装。
+・以下のようにイベントを処理するクラスを実装し、DataTransferServiceでそのオブジェクトを保持した。サービスインターフェースにそのオブジェクトを返すようなメソッドを定義し実装したが、期待通りの動作をしてくれなかった。
-双方向通信
+```C#
+[DataContract]
+    public class EventHelper
+    {
+        public delegate void CallbackEventHandler(object sender, CommunicationEventArgs args);
+        [field: DataMember]
+        public event CallbackEventHandler OnCallback;
+        [OperationContract]
+        public void Fire(UInt32 id, byte[] message)
+        {
+            this.OnCallback?.Invoke(this, new CommunicationEventArgs(id, message));
+        }
+    }
+```
 ### 補足情報（FW/ツールのバージョンなど）
 Visual  Studio 2019

ソースコードを追加しました。

2019/09/18 12:03

投稿

kaito_19950605

スコア4

title CHANGED Viewed

File without changes

body CHANGED Viewed

@@ -7,22 +7,294 @@
 WCFを利用したプロセス間のイベント通知によるデータ転送の実現方法を教えて頂きたいです。
 英語のサイトでも構いません。
-漠然とした質問で申し訳ございません。
 ### 発生している問題・エラーメッセージ
 WCFによるプロセス間のイベント通知が出来ない。
 ### 該当のソースコード
+サービスの定義（IdataTransferService.cs）
 ```C#
+namespace DataTransferWCFService
+{
+    // メモ: [リファクター] メニューの [名前の変更] コマンドを使用すると、コードと config ファイルの両方で同時にインターフェイス名 "IService1" を変更できます。
+    [ServiceContract(CallbackContract = typeof(IGetResponseCallback))]
+    public interface IDataTransferService
+    {
+        // TODO: ここにサービス操作を追加します。
+        [OperationContract(IsOneWay = true)]
+        void Register(byte[] data);
+        [OperationContract(IsOneWay = true)]
-ソースコード
+        void Clear();
+        [OperationContract]
+        byte[] GetResponse(UInt32 id, byte[] request);
+    }
+    // サービス操作に複合型を追加するには、以下のサンプルに示すようにデータ コントラクトを使用します。
+    // プロジェクトに XSD ファイルを追加できます。プロジェクトのビルド後、そこで定義されたデータ型を、名前空間 "DataTransferWCFService.ContractType" で直接使用できます。
+}
 ```
+コールバックインターフェースの定義（IGetResponseCallback.cs）
+```C#
+namespace DataTransferWCFService
+{
+    public interface IGetResponseCallback
+    {
+        [OperationContract(IsOneWay = true)]
+        void GetResponseCallback(UInt32 id, byte[] message);
+    }
+}
+```
+サービスの実装（DataTransferService.cs）
+```C#
+namespace DataTransferWCFService
+{
+    // メモ: [リファクター] メニューの [名前の変更] コマンドを使用すると、コードと config ファイルの両方で同時にクラス名 "Service1" を変更できます。
+    public class DataTransferService : IDataTransferService, IGetResponseCallback
+    {
+        private static List<byte[]> dataList = new List<byte[]>();
+        public delegate void CallbackEventHandler(object sender, CommunicationEventArgs args);
+        public event CallbackEventHandler OnCallback;
+        public void Clear()
+        {
+            dataList.Clear();
+        }
+        public byte[] GetResponse(uint id, byte[] request)
+        {
+            IGetResponseCallback callback = OperationContext.Current.GetCallbackChannel<IGetResponseCallback>();
+            byte[] response = dataList.ElementAt((int)id)
+                                       .Concat(request)
+                                       .ToArray();
+            callback.GetResponseCallback(id, response);
+            return response;
+        }
+        public void GetResponseCallback(uint id, byte[] message)
+        {
+            this.OnCallback?.Invoke(this, new CommunicationEventArgs(id, message));
+        }
+        public void Register(byte[] data)
+        {
+            dataList.Add(data);
+        }
+    }
+}
+```
+サービスの開始周り（DataTransfer.cs）
+```C#
+namespace DataTransfer
+{
+    public class DataTransfer
+    {
+        public DataTransferService DataTransferServiceInstance
+        {
+            get
+            {
+                return _DataTransfer.dtService;
+            }
+        }
+        public void Register(byte[] data)
+        {
+            _DataTransfer.Register(data);
+        }
+        public void Clear()
+        {
+            _DataTransfer.Clear();
+        }
+        public byte[] GetResponse(UInt32 id, byte[] request)
+        {
+            return _DataTransfer.GetResponse(id, request);
+        }
+    }
+    static class _DataTransfer
+    {
+        private static string pipeName = @"net.pipe://sample";
+        private static ServiceHost host;
+        private static IDataTransferService client;
+        static DuplexChannelFactory<IDataTransferService> factory;
+        public static DataTransferService dtService = new DataTransferService();
+        static _DataTransfer()
+        {
+            host = new ServiceHost(typeof(IDataTransferService), new Uri(pipeName));
+            host.AddServiceEndpoint(typeof(IDataTransferService), new NetNamedPipeBinding(NetNamedPipeSecurityMode.None)
+            {
+                ReceiveTimeout = TimeSpan.MaxValue
+            }, string.Empty);
+            try
+            {
+                host.Open();
+            }
+            catch(Exception ex)
+            {
+                Debug.WriteLine(ex.Message);
+            }
+            Create();
+        }
+        public static void Create()
+        {
+            factory = new DuplexChannelFactory<IDataTransferService>(new InstanceContext(dtService), new NetNamedPipeBinding(NetNamedPipeSecurityMode.None)
+            {
+                MaxReceivedMessageSize = Int32.MaxValue
+            }, pipeName);
+            client = factory.CreateChannel();
+        }
+        public static void Clear()
+        {
+            try
+            {
+                client.Clear();
+            }
+            catch(Exception ex)
+            {
+                Debug.WriteLine(ex.Message);
+            }
+        }
+        public static void Register(byte[] data)
+        {
+            try
+            {
+                client.Register(data);
+            }
+            catch(Exception ex)
+            {
+                Debug.WriteLine(ex.Message);
+            }
+        }
+        public static byte[] GetResponse(UInt32 id, byte[] request)
+        {
+            try
+            {
+                return client.GetResponse(id, request);
+            }
+            catch(Exception ex)
+            {
+                Debug.WriteLine(ex.Message);
+                return null;
+            }
+        }
+    }
+}
+```
+WCFの設定ファイル（App.config）
+```XML
+<?xml version="1.0" encoding="utf-8" ?>
+<configuration>
+  <appSettings>
+    <add key="aspnet:UseTaskFriendlySynchronizationContext" value="true" />
+  </appSettings>
+  <system.web>
+    <compilation debug="true" />
+  </system.web>
+  <!-- サービス ライブラリ プロジェクトの展開時に、構成ファイルの内容をホストの app.config ファイルに追加する
+  必要があります。System.Configuration は、ライブラリの構成ファイルをサポートしていません。 -->
+  <system.serviceModel>
+    <services>
+      <service name="DataTransferWCFService.DataTransferService">
+        <endpoint address="" binding="wsDualHttpBinding" contract="DataTransferWCFService.IDataTransferService">
+          <identity>
+            <dns value="localhost" />
+          </identity>
+        </endpoint>
+        <endpoint address="mex" binding="mexHttpBinding" contract="IMetadataExchange" />
+        <host>
+          <baseAddresses>
+            <add baseAddress="http://localhost:8733/Design_Time_Addresses/DataTransferWCFService/Service1/" />
+          </baseAddresses>
+        </host>
+      </service>
+    </services>
+    <behaviors>
+      <serviceBehaviors>
+        <behavior>
+          <!-- メタデータ情報の開示を避けるには、
+          展開する前に下の値を false に設定します -->
+          <serviceMetadata httpGetEnabled="True" httpsGetEnabled="True"/>
+          <!-- デバッグ目的で障害発生時の例外の詳細を受け取るには、
+          下の値を true に設定します。例外情報の開示を避けるには、
+          展開する前に false に設定します -->
+          <serviceDebug includeExceptionDetailInFaults="False" />
+        </behavior>
+      </serviceBehaviors>
+    </behaviors>
+  </system.serviceModel>
+</configuration>
+```
+本体（Program.cs）
+```C#
+namespace WCFIPC
+{
+    class Program
+    {
+        static void Main(string[] args)
+        {
+            //1つ目のプロセスでは
+            Transfer transfer = new Transfer();
+            transfer.Register(new byte[] { 0x12, 0x34, 0x56 });
+            //2つ目のプロセスでは
+            DataTransfer.DataTransfer dataTransfer = new DataTransfer.DataTransfer();
+            var response = dataTransfer.GetResponse(0xFF, new byte[] { 0x78, 0x90 });
+        }
+    }
+    class Transfer
+    {
+        public DataTransfer.DataTransfer service = new DataTransfer.DataTransfer();
+        public void Register(byte[] data)
+        {
+            this.service.Register(data);
+            //ここでプロセス間のイベントを購読したい
+            this.service.DataTransferServiceInstance.OnCallback += DataTransferServiceInstance_OnCallback;
+        }
+        private void DataTransferServiceInstance_OnCallback(object sender, DataTransferWCFService.CommunicationEventArgs args)
+        {
+            Console.Write(args.Message);
+        }
+        public void Clear()
+        {
+            this.service.Clear();
+        }
+    }
+}
+```
 ### 試したこと
 双方向通信
 ### 補足情報（FW/ツールのバージョンなど）
-Visual  Studio 2019
+Visual  Studio 2019
+.NET Framework 4.7.2