chore: 处理警告；release version

Author: Cyaim

Cyaim.WebSocketServer/Cluster/Cyaim.WebSocketServer.Cluster.RabbitMQ/RabbitMQClusterTransport.cs

@@ -123,6 +123,13 @@ public async Task StartAsync()
                         var messageJson = Encoding.UTF8.GetString(body);
                         var clusterMessage = JsonSerializer.Deserialize<ClusterMessage>(messageJson);
 
+                        if (clusterMessage == null)
+                        {
+                            _logger.LogWarning("Received null or invalid message from RabbitMQ");
+                            await _channel.BasicAckAsync(ea.DeliveryTag, false);
+                            return;
+                        }
+                        
                         // Skip messages from self / 跳过来自自己的消息
                         if (clusterMessage.FromNodeId == _nodeId)
                         {

Cyaim.WebSocketServer/Cyaim.WebSocketServer.SourceGenerator/EndpointInjectorGenerator.cs

@@ -69,14 +69,14 @@ public void Execute(GeneratorExecutionContext context)
             }
         }
 
-        private IPropertySymbol FindProperty(INamedTypeSymbol classSymbol, string propertyName)
+        private IPropertySymbol? FindProperty(INamedTypeSymbol classSymbol, string propertyName)
         {
             return classSymbol.GetMembers(propertyName)
                 .OfType<IPropertySymbol>()
                 .FirstOrDefault(p => p.SetMethod != null && !p.SetMethod.IsStatic);
         }
 
-        private string GenerateInjectorCode(string namespaceName, string className, string classFullName, IPropertySymbol httpContextProperty, IPropertySymbol webSocketProperty)
+        private string GenerateInjectorCode(string namespaceName, string className, string classFullName, IPropertySymbol? httpContextProperty, IPropertySymbol? webSocketProperty)
         {
             var sb = new StringBuilder();
             sb.AppendLine("using Cyaim.WebSocketServer.Infrastructure.Injectors;");

Cyaim.WebSocketServer/Cyaim.WebSocketServer/Infrastructure/Cluster/ClusterChannelHandler.cs

@@ -89,6 +89,11 @@ private static async Task HandleClusterConnection(WebSocket webSocket, HttpConte
                     try
                     {
                         var message = JsonSerializer.Deserialize<ClusterMessage>(messageJson);
+                        if (message == null)
+                        {
+                            logger.LogWarning("Received null or invalid cluster message");
+                            continue;
+                        }
 
                         // Identify the node from the message
                         // 从消息中识别节点

Cyaim.WebSocketServer/Cyaim.WebSocketServer/Infrastructure/Cluster/Transports/WebSocketClusterTransport.cs

@@ -271,6 +271,11 @@ private async Task ReceiveMessagesAsync(string nodeId, WebSocket webSocket)
                         try
                         {
                             var message = JsonSerializer.Deserialize<ClusterMessage>(messageJson);
+                            if (message == null)
+                            {
+                                _logger.LogWarning($"Received null or invalid message from node {nodeId}");
+                                continue;
+                            }
                             message.FromNodeId = nodeId;
 
                             MessageReceived?.Invoke(this, new ClusterMessageEventArgs