編集履歴

質問編集履歴

2019/09/18 22:03

投稿

kaito_19950605

スコア4

test CHANGED Viewed

File without changes

test CHANGED Viewed

@@ -36,6 +36,14 @@
+下記のソースコードのようにすると、以下のようになってしまいます。
+1. 1つ目のプロセスでイベント登録(OnCallback)。
+2. 2つ目のプロセスでInvokeしようとすると、OnCallbackがnullになっていてInvokeされない。
 ### 該当のソースコード

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

2019/09/18 22:03

投稿

kaito_19950605

スコア4

test CHANGED Viewed

File without changes

test CHANGED Viewed

@@ -16,6 +16,14 @@
+ClientとServiceの双方向通信のサンプルはネット上にたくさん転がっていますが、
+あるClientがイベントを叩くと、もう一方のClientにイベント通知がされる、
+というパターンが見つかりませんでした。
 参考としてサイトをご紹介頂ける場合は、英語のサイトでも構いません。

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

2019/09/18 12:08

投稿

kaito_19950605

スコア4

test CHANGED Viewed

File without changes

test CHANGED Viewed

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

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

2019/09/18 12:05

投稿

kaito_19950605

スコア4

test CHANGED Viewed

File without changes

test CHANGED Viewed

@@ -8,11 +8,11 @@
 プロセス間でイベント通知を行い、データを転送したいのですが、双方向通信にしてもイベントが飛びません。
 WCFを利用したプロセス間のイベント通知によるデータ転送の実現方法を教えて頂きたいです。
-英語のサイトでも構いません。
+参考としてサイトをご紹介頂ける場合は、英語のサイトでも構いません。
@@ -36,37 +36,45 @@
 {
-    // メモ: [リファクター] メニューの [名前の変更] コマンドを使用すると、コードと 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" で直接使用できます。
 }
@@ -106,490 +114,524 @@
 {
-    // メモ: [リファクター] メニューの [名前の変更] コマンドを使用すると、コードと config ファイルの両方で同時にクラス名 "Service1" を変更できます。
-    public class DataTransferService : IDataTransferService, IGetResponseCallback
+    public class DataTransferService : IDataTransferService
     {
         private static List<byte[]> dataList = new List<byte[]>();
+        public void Clear()
+        {
+            dataList.Clear();
+        }
+        public byte[] GetResponse(uint id, byte[] request)
+        {
+            byte[] response = dataList.ElementAt((int)id)
+                                       .Concat(request)
+                                       .ToArray();
+            return response;
+        }
+        public void Register(byte[] data)
+        {
+            dataList.Add(data);
+        }
+        /// <summary>
+        /// コールバック用
+        /// </summary>
+        /// <param name="id"></param>
+        /// <param name="request"></param>
+        public void Send(uint id, byte[] message)
+        {
+            IGetResponseCallback callback = OperationContext.Current.GetCallbackChannel<IGetResponseCallback>();
+            callback.GetResponseCallback(id, message);
+        }
+    }
+}
+```
+サービスの開始周り（DataTransfer.cs）
+```C#
+namespace DataTransfer
+{
+    public class DataTransfer
+    {
+        public _DataTransfer instance = _DataTransfer.Instance;
+        /// <summary>
+        /// サービスの開始とチャンネルの実体化
+        /// </summary>
+        public void PreStart()
+        {
+            this.instance.Start();
+            this.instance.Create();
+        }
+        /// <summary>
+        /// チャンネルの実体化
+        /// </summary>
+        public void Create()
+        {
+            this.instance.Create();
+        }
+        public void Register(byte[] data)
+        {
+            this.instance.Register(data);
+        }
+        public void Clear()
+        {
+            this.instance.Clear();
+        }
+        public byte[] GetResponse(UInt32 id, byte[] request)
+        {
+            return this.instance.GetResponse(id, request);
+        }
+    }
+    public class _DataTransfer : IGetResponseCallback
+    {
+        private static string PIPE_NAME = @"net.pipe://sample";
+        public ServiceHost host;
+        public IDataTransferService proxy;
+        public DuplexChannelFactory<IDataTransferService> factory;
         public delegate void CallbackEventHandler(object sender, CommunicationEventArgs args);
         public event CallbackEventHandler OnCallback;
+        //シングルトンパターン
+        private static _DataTransfer instance = new _DataTransfer();
+        public static _DataTransfer Instance
+        {
+            get
+            {
+                return instance;
+            }
+        }
+        private _DataTransfer()
+        {
+        }
+        /// <summary>
+        /// サービスを開始
+        /// </summary>
+        public void Start()
+        {
+            Instance.host = new ServiceHost(typeof(IDataTransferService), new Uri(PIPE_NAME));
+            Instance.host.AddServiceEndpoint(typeof(IDataTransferService), new NetNamedPipeBinding(NetNamedPipeSecurityMode.None)
+            {
+                ReceiveTimeout = TimeSpan.MaxValue
+            }, string.Empty);
+            try
+            {
+                host.Open();
+            }
+            catch (Exception ex)
+            {
+                Debug.WriteLine(ex.Message);
+            }
+        }
+        /// <summary>
+        /// チャンネルの実体化
+        /// </summary>
+        public void Create()
+        {
+            Instance.factory = new DuplexChannelFactory<IDataTransferService>(new InstanceContext(Instance), new NetNamedPipeBinding(NetNamedPipeSecurityMode.None)
+            {
+                MaxReceivedMessageSize = Int32.MaxValue
+            }, PIPE_NAME);
+            Instance.proxy = Instance.factory.CreateChannel();
+        }
         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;
-        }
+            try
+            {
+                Instance.proxy.Clear();
+            }
+            catch(Exception ex)
+            {
+                Debug.WriteLine(ex.Message);
+            }
+        }
+        public void Register(byte[] data)
+        {
+            try
+            {
+                Instance.proxy.Register(data);
+            }
+            catch(Exception ex)
+            {
+                Debug.WriteLine(ex.Message);
+            }
+        }
+        public byte[] GetResponse(UInt32 id, byte[] request)
+        {
+            try
+            {
+                Instance.proxy.Send(id, request);
+                byte[] response = Instance.proxy.GetResponse(id, request);
+                Instance.proxy.Send(id, response);
+                return response;
+            }
+            catch(Exception ex)
+            {
+                Debug.WriteLine(ex.Message);
+                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));
+        }
+    }
+}
+```
+本体（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();
+            dataTransfer.Create();
+            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.PreStart();
+            this.service.Register(data);
+            //ここでイベントの購読をしたい
+            this.service.instance.OnCallback += Instance_OnCallback;
+        }
+        private void Instance_OnCallback(object sender, DataTransferWCFService.CommunicationEventArgs args)
+        {
+            Console.Write(args.Message);
+        }
+        public void Clear()
+        {
+            this.service.Clear();
+        }
+    }
+}
+```
+### 試したこと
+・上記実装。
+・以下のようにイベントを処理するクラスを実装し、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));
         }
-        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/ツールのバージョンなど）

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

2019/09/18 12:03

投稿

kaito_19950605

スコア4

test CHANGED Viewed

File without changes

test CHANGED Viewed

@@ -16,10 +16,6 @@
-漠然とした質問で申し訳ございません。
 ### 発生している問題・エラーメッセージ
@@ -32,14 +28,560 @@
+サービスの定義（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();
+        }
+    }
+}
+```
 ### 試したこと
@@ -53,3 +595,5 @@
 Visual  Studio 2019
+.NET Framework 4.7.2