添加库定义通讯

dotnet-campus · Nov 16, 2023 · 8c39bad · 8c39bad
1 parent d714c6e
commit 8c39bad
Show file tree

Hide file tree

Showing 3 changed files with 50 additions and 1 deletion.
diff --git a/demo/UnoDemo/IpcUno/Directory.Packages.props b/demo/UnoDemo/IpcUno/Directory.Packages.props
@@ -1,6 +1,7 @@
 <Project ToolsVersion="15.0">
   <ItemGroup>
     <PackageVersion Include="CommunityToolkit.Mvvm" Version="8.2.1" />
+    <PackageVersion Include="dotnetCampus.Ipc" Version="2.0.0-alpha409" />
     <PackageVersion Include="Microsoft.Maui.Controls" Version="$(MauiVersion)" />
     <PackageVersion Include="Microsoft.Maui.Controls.Compatibility" Version="$(MauiVersion)" />
     <PackageVersion Include="Microsoft.Extensions.Logging.Console" Version="8.0.0-rc.2.23479.6" />
@@ -36,4 +37,4 @@
     <PackageVersion Include="Uno.UITest.Helpers" Version="1.1.0-dev.70" />
     <PackageVersion Include="Xamarin.UITest" Version="4.3.0" />
   </ItemGroup>
-</Project>
+</Project>
diff --git a/demo/UnoDemo/IpcUno/IpcUno/Business/Models/ConnectedPeerModel.cs b/demo/UnoDemo/IpcUno/IpcUno/Business/Models/ConnectedPeerModel.cs
@@ -0,0 +1,47 @@
+using System.Collections.ObjectModel;
+
+using dotnetCampus.Ipc.Context;
+using dotnetCampus.Ipc.Messages;
+using dotnetCampus.Ipc.Pipes;
+
+using Windows.ApplicationModel.Core;
+using Windows.UI.Core;
+
+namespace IpcUno.Business.Models
+{
+    public class ConnectedPeerModel
+    {
+        public ConnectedPeerModel()
+        {
+            Peer = null!;
+        }
+
+        public ConnectedPeerModel(PeerProxy peer)
+        {
+            Peer = peer;
+            peer.MessageReceived += Peer_MessageReceived;
+        }
+
+        private void Peer_MessageReceived(object? sender, IPeerMessageArgs e)
+        {
+            var streamReader = new StreamReader(e.Message.Body.ToMemoryStream());
+            var message = streamReader.ReadToEnd();
+
+            _ = CoreApplication.MainView.CoreWindow.Dispatcher.RunAsync(CoreDispatcherPriority.Normal, () => 
+            {
+                AddMessage(PeerName, message);
+            });
+        }
+
+        public void AddMessage(string name, string message)
+        {
+            MessageList.Add($"{name} {DateTime.Now:yyyy/MM/dd hh:mm:ss.fff}:\r\n{message}");
+        }
+
+        public ObservableCollection<string> MessageList { get; } = new ObservableCollection<string>();
+
+        public PeerProxy Peer { get; }
+
+        public string PeerName => Peer.PeerName;
+    }
+}
diff --git a/demo/UnoDemo/IpcUno/IpcUno/IpcUno.csproj b/demo/UnoDemo/IpcUno/IpcUno/IpcUno.csproj
@@ -9,6 +9,7 @@
   </PropertyGroup>
 
   <ItemGroup>
+    <PackageReference Include="dotnetCampus.Ipc" />
     <PackageReference Include="Uno.WinUI" />
     <PackageReference Include="Uno.Resizetizer" />
     <PackageReference Include="CommunityToolkit.Mvvm" />