up

FrmMain.cs

@@ -32,13 +32,13 @@ namespace Test
             //连接操作
             btnConnect.Enabled=false;
             _client = new ServerEventsClient(tbxServiceUrl.Text);
-            _client.OnConnect = onConnected;
-            _client.OnCommand = onCommand;
-            _client.OnMessage = onMessage;
-            _client.OnException = onException;
-            _client.OnHeartbeat = onHeartbeat;
+            _client.OnConnect = onConnected;//连接成功
+            _client.OnCommand = onCommand;//收到命令
+            _client.OnMessage = onMessage;//收到消息
+            _client.OnException = onException;//发生异常
+            _client.OnHeartbeat = onHeartbeat;//心跳
             _client.Handlers["test"] = testHandler;
-
+            _client.Channels = tbxConnectChannels.Text.Split(new char[1] { ','},StringSplitOptions.RemoveEmptyEntries);
             //如果用户名为空，匿名连接
             if (tbxUserName.Text.IsNullOrEmpty())
             {
@@ -46,9 +46,9 @@ namespace Test
                 return;
             }
             var auth = new Authenticate { UserName =tbxUserName.Text, Password = tbxPassword.Text, provider = "kivii" };
-            var task=_client.ServiceClient.PostAsync(auth);
+            //_client.ServiceClient.PostAsync(auth);
+            var task=_client.AuthenticateAsync(auth);//等同于_client.ServiceClient.PostAsync
             task.Success((res)=>{
-                tbxAuthSessionId.Text = res.SessionId;
                 //登陆成功后连接ServerEvents，设置事件
                 _client.Connect();
             }, true);
@@ -83,7 +83,7 @@ namespace Test
             tbxSubscriptionId.Text = connection.SubscriptionId;
             tbxSessionId.Text = connection.SessionId;
             tbxChannels.Text = connection.Channels?.Join(",");
-
+            tbxUserId.Text = connection.UserId;
             tbxConnectedTime.Text = DateTime.Now.ToString("HH:mm:ss");
             tbxConnectedTime.BackColor = tbxConnectedTime.BackColor != Color.MistyRose ? Color.MistyRose : Color.YellowGreen;
 
@@ -157,6 +157,7 @@ namespace Test
             btnRemoveChannel.Enabled = false;
             var task=_client.UnsubscribeFromChannelsAsync(tbxUpdateChannel.Text.Split(new char[1] { ',' }, StringSplitOptions.RemoveEmptyEntries));
             task.Success(()=>{
+                tbxChannels.Text = _client.Channels.Join(",");
                 btnRemoveChannel.Enabled = true;
             });
             task.Error((ex)=> {
@@ -172,6 +173,7 @@ namespace Test
             btnAddChannel.Enabled = false;
             var task = _client.SubscribeToChannelsAsync(tbxUpdateChannel.Text.Split(new char[1] { ',' }, StringSplitOptions.RemoveEmptyEntries));
             task.Success(() => {
+                tbxChannels.Text = _client.Channels.Join(",");
                 btnAddChannel.Enabled = true;
             });
             task.Error((ex) => {

Kivii.Client.ServerEvent.Test.csproj

@@ -32,8 +32,9 @@
     <WarningLevel>4</WarningLevel>
   </PropertyGroup>
   <ItemGroup>
-    <Reference Include="Kivii.Common.V4.5, Version=5.6.2022.8200, Culture=neutral, processorArchitecture=MSIL">
-      <HintPath>packages\Kivii.Common.5.6.2022.8200\lib\net45\Kivii.Common.V4.5.dll</HintPath>
+    <Reference Include="Kivii.Common.V4.5, Version=5.6.2024.1140, Culture=neutral, processorArchitecture=MSIL">
+      <SpecificVersion>False</SpecificVersion>
+      <HintPath>..\..\localhost\net45\app\Kivii.Common.V4.5.dll</HintPath>
     </Reference>
     <Reference Include="System" />
     <Reference Include="System.Core" />

packages.config

 <?xml version="1.0" encoding="utf-8"?>
 <packages>
-  <package id="Kivii.Common" version="5.6.2022.8200" targetFramework="net45" />
+  <package id="Kivii.Common" version="5.6.2024.1140" targetFramework="net45" />
 </packages>
\ No newline at end of file