861 lines
33 KiB
C#
861 lines
33 KiB
C#
using XiaoZhiSharp;
|
||
using XiaoZhiSharp.Protocols;
|
||
using System.Collections.ObjectModel;
|
||
using System.IO.Pipelines;
|
||
using ModelContextProtocol.Client;
|
||
using ModelContextProtocol.Protocol;
|
||
using System.Text.Encodings.Web;
|
||
using System.Text.Json;
|
||
using System.Text.Json.Nodes;
|
||
using Microsoft.Extensions.DependencyInjection;
|
||
using Microsoft.Extensions.Hosting;
|
||
using XiaoZhiSharp_MauiBlazorApp.McpTools;
|
||
using ModelContextProtocol.Protocol;
|
||
using System.Text.Encodings.Web;
|
||
using System.Text.Json;
|
||
using System.Text.Json.Nodes;
|
||
using Microsoft.Extensions.DependencyInjection;
|
||
using Microsoft.Extensions.Hosting;
|
||
using XiaoZhiSharp_MauiBlazorApp.McpTools;
|
||
using System.Net.WebSockets;
|
||
using XiaoZhiSharp.Models;
|
||
|
||
namespace XiaoZhiSharp_MauiBlazorApp.Services
|
||
{
|
||
// 聊天消息类
|
||
public class ChatMessage
|
||
{
|
||
public string Content { get; set; } = "";
|
||
public bool IsUser { get; set; } = false;
|
||
public DateTime Timestamp { get; set; } = DateTime.Now;
|
||
|
||
public ChatMessage(string content, bool isUser)
|
||
{
|
||
Content = content;
|
||
IsUser = isUser;
|
||
Timestamp = DateTime.Now;
|
||
}
|
||
}
|
||
|
||
public class XiaoZhi_AgentService : IDisposable
|
||
{
|
||
private readonly XiaoZhiAgent _agent;
|
||
private bool _disposed = false;
|
||
|
||
// MCP相关字段
|
||
private IMcpClient _mcpClient = null!;
|
||
private Pipe _clientToServerPipe = new Pipe();
|
||
private Pipe _serverToClientPipe = new Pipe();
|
||
private IHost? _host;
|
||
|
||
public string QuestionMessae = "";
|
||
public string AnswerMessae = "";
|
||
public string Emotion = "normal";
|
||
public float AudioLevel = 0.0f; // 音频强度 0-1
|
||
public bool IsConnected = false; // 连接状态
|
||
|
||
// 设置相关属性
|
||
public string ServerUrl { get; set; } = "wss://api.tenclass.net/xiaozhi/v1/";
|
||
public string OtaUrl { get; set; } = "https://api.tenclass.net/xiaozhi/ota/";
|
||
public string DeviceId { get; set; } = Global.DeviceId;
|
||
public int VadThreshold { get; set; } = 40;
|
||
public bool IsDebugMode { get; set; } = false;
|
||
|
||
// VAD配置（从Unity版本移植）
|
||
public bool UseVAD { get; set; } = true;
|
||
public float VadEnergyThreshold { get; set; } = 0.015f;
|
||
public int VadSilenceFrames { get; set; } = 20;
|
||
public float TtsCooldownTime { get; set; } = 0.5f;
|
||
|
||
// OTA 相关信息
|
||
public OtaResponse? LatestOtaResponse { get; private set; }
|
||
public string OtaStatus { get; private set; } = "未检查";
|
||
public DateTime? LastOtaCheckTime { get; private set; }
|
||
public string? ActivationCode { get; private set; }
|
||
public string? ActivationMessage { get; private set; }
|
||
public string? FirmwareVersion { get; private set; }
|
||
public string? FirmwareUrl { get; private set; }
|
||
public DateTime? ServerTime { get; private set; }
|
||
public string? MqttEndpoint { get; private set; }
|
||
public ObservableCollection<string> DebugLogs { get; private set; } = new();
|
||
|
||
// 版本信息
|
||
public string CurrentVersion { get; private set; } = "1.0.0"; // 当前版本
|
||
public string? LatestVersion { get; private set; } // 最新版本
|
||
public bool NeedUpdate { get; private set; } = false; // 是否需要更新
|
||
public string UpdateMessage { get; private set; } = ""; // 更新提示信息
|
||
|
||
// 聊天历史记录
|
||
public ObservableCollection<ChatMessage> ChatHistory { get; private set; } = new();
|
||
|
||
public XiaoZhiAgent Agent
|
||
{
|
||
get { return _agent; }
|
||
}
|
||
public int VadCounter
|
||
{
|
||
get { return _agent.AudioService?.VadCounter ?? 0; }
|
||
}
|
||
public bool IsRecording
|
||
{
|
||
get { return _agent.AudioService?.IsRecording ?? false; }
|
||
}
|
||
|
||
private System.Timers.Timer? _connectionMonitorTimer;
|
||
private DateTime _lastReconnectAttempt = DateTime.MinValue;
|
||
private int _reconnectAttempts = 0;
|
||
private const int MaxReconnectAttempts = 5; // 最大重连尝试次数
|
||
private const int ReconnectInterval = 5000; // 重连间隔(毫秒)
|
||
|
||
public XiaoZhi_AgentService()
|
||
{
|
||
// 从配置初始化设置
|
||
LoadSettings();
|
||
|
||
// 获取当前版本（可以从应用程序信息中获取）
|
||
CurrentVersion = AppInfo.VersionString ?? "1.0.0";
|
||
|
||
XiaoZhiSharp.Global.VadThreshold = VadThreshold;
|
||
XiaoZhiSharp.Global.IsDebug = IsDebugMode;
|
||
XiaoZhiSharp.Global.IsMcp = true; // 启用MCP协议支持
|
||
//XiaoZhiSharp.Global.IsAudio = false;
|
||
_agent = new XiaoZhiAgent();
|
||
_agent.DeviceId = DeviceId;
|
||
_agent.WsUrl = ServerUrl;
|
||
_agent.OtaUrl = OtaUrl;
|
||
_agent.OnMessageEvent += Agent_OnMessageEvent;
|
||
_agent.OnAudioPcmEvent += Agent_OnAudioPcmEvent;
|
||
_agent.OnOtaEvent += Agent_OnOtaEvent;
|
||
|
||
// 根据平台注册相应的音频服务
|
||
if (DeviceInfo.Platform == DevicePlatform.Android)
|
||
{
|
||
try
|
||
{
|
||
var audioService = new Services.AudioService();
|
||
// 配置VAD参数
|
||
//audioService.ConfigureVAD(UseVAD, VadEnergyThreshold, VadSilenceFrames, TtsCooldownTime);
|
||
_agent.AudioService = audioService;
|
||
AddDebugLog($"已初始化Android音频服务并配置VAD: 启用={UseVAD}, 阈值={VadEnergyThreshold}, 静音帧数={VadSilenceFrames}, 冷却时间={TtsCooldownTime}秒");
|
||
}
|
||
catch (Exception ex)
|
||
{
|
||
AddDebugLog($"音频服务初始化失败: {ex.Message}");
|
||
}
|
||
}
|
||
else if (DeviceInfo.Platform == DevicePlatform.WinUI)
|
||
{
|
||
//_agent.AudioService = new Services.AudioService();
|
||
AddDebugLog("Windows平台暂未实现音频服务");
|
||
}
|
||
|
||
// 初始化MCP服务
|
||
InitializeMcpService();
|
||
|
||
_ = Task.Run(async () => await _agent.Start());
|
||
IsConnected = true; // 假设启动后就连接成功
|
||
|
||
// 启动连接状态监测定时器
|
||
StartConnectionMonitor();
|
||
}
|
||
|
||
// 初始化MCP服务
|
||
private void InitializeMcpService()
|
||
{
|
||
try
|
||
{
|
||
var builder = Host.CreateApplicationBuilder();
|
||
|
||
builder.Services
|
||
.AddMcpServer()
|
||
.WithStreamServerTransport(_clientToServerPipe.Reader.AsStream(), _serverToClientPipe.Writer.AsStream())
|
||
.WithTools<IotThings_Tool>()
|
||
.WithTools<Chrome_Tool>()
|
||
.WithTools<WindowsApp_Tool>();
|
||
|
||
_host = builder.Build();
|
||
_host.StartAsync();
|
||
|
||
AddDebugLog("MCP服务初始化成功");
|
||
}
|
||
catch (Exception ex)
|
||
{
|
||
AddDebugLog($"MCP服务初始化失败: {ex.Message}");
|
||
}
|
||
}
|
||
|
||
private void LoadSettings()
|
||
{
|
||
// 从Preferences加载设置
|
||
ServerUrl = Preferences.Get("ServerUrl", "wss://api.tenclass.net/xiaozhi/v1/");
|
||
OtaUrl = Preferences.Get("OtaUrl", "https://api.tenclass.net/xiaozhi/ota/");
|
||
DeviceId = Preferences.Get("DeviceId", Global.DeviceId);
|
||
VadThreshold = Preferences.Get("VadThreshold", 40);
|
||
IsDebugMode = Preferences.Get("IsDebugMode", false);
|
||
|
||
// 加载VAD配置
|
||
UseVAD = Preferences.Get("UseVAD", true);
|
||
VadEnergyThreshold = Preferences.Get("VadEnergyThreshold", 0.015f);
|
||
VadSilenceFrames = Preferences.Get("VadSilenceFrames", 20);
|
||
TtsCooldownTime = Preferences.Get("TtsCooldownTime", 0.5f);
|
||
}
|
||
|
||
public void SaveSettings()
|
||
{
|
||
// 保存设置到Preferences
|
||
Preferences.Set("ServerUrl", ServerUrl);
|
||
Preferences.Set("OtaUrl", OtaUrl);
|
||
Preferences.Set("DeviceId", DeviceId);
|
||
Preferences.Set("VadThreshold", VadThreshold);
|
||
Preferences.Set("IsDebugMode", IsDebugMode);
|
||
|
||
// 保存VAD配置
|
||
Preferences.Set("UseVAD", UseVAD);
|
||
Preferences.Set("VadEnergyThreshold", VadEnergyThreshold);
|
||
Preferences.Set("VadSilenceFrames", VadSilenceFrames);
|
||
Preferences.Set("TtsCooldownTime", TtsCooldownTime);
|
||
}
|
||
|
||
public async Task ApplySettings()
|
||
{
|
||
// 应用设置并重启连接
|
||
SaveSettings();
|
||
|
||
// 更新全局配置
|
||
XiaoZhiSharp.Global.VadThreshold = VadThreshold;
|
||
XiaoZhiSharp.Global.IsDebug = IsDebugMode;
|
||
|
||
// 更新Agent配置
|
||
_agent.DeviceId = DeviceId;
|
||
_agent.WsUrl = ServerUrl;
|
||
_agent.OtaUrl = OtaUrl;
|
||
|
||
// 更新音频服务的VAD配置
|
||
if (_agent.AudioService != null && DeviceInfo.Platform == DevicePlatform.Android)
|
||
{
|
||
var audioService = _agent.AudioService as Services.AudioService;
|
||
//audioService?.ConfigureVAD(UseVAD, VadEnergyThreshold, VadSilenceFrames, TtsCooldownTime);
|
||
}
|
||
|
||
// 重启连接
|
||
await _agent.Restart();
|
||
|
||
// 重置VAD配置
|
||
if (_agent.AudioService != null && DeviceInfo.Platform == DevicePlatform.Android)
|
||
{
|
||
var audioService = _agent.AudioService as Services.AudioService;
|
||
//audioService?.ConfigureVAD(UseVAD, VadEnergyThreshold, VadSilenceFrames, TtsCooldownTime);
|
||
AddDebugLog("连接重启后，已重置VAD参数");
|
||
}
|
||
}
|
||
|
||
public void ResetSettings()
|
||
{
|
||
// 重置为默认值
|
||
ServerUrl = "wss://api.tenclass.net/xiaozhi/v1/";
|
||
OtaUrl = "https://api.tenclass.net/xiaozhi/ota/";
|
||
DeviceId = Global.DeviceId;
|
||
VadThreshold = 40;
|
||
IsDebugMode = false;
|
||
|
||
// 重置VAD配置为默认值
|
||
UseVAD = true;
|
||
VadEnergyThreshold = 0.015f;
|
||
VadSilenceFrames = 20;
|
||
TtsCooldownTime = 0.5f;
|
||
}
|
||
|
||
private async Task Agent_OnAudioPcmEvent(byte[] pcm)
|
||
{
|
||
// 计算音频强度
|
||
AudioLevel = CalculateAudioLevel(pcm);
|
||
}
|
||
|
||
private float CalculateAudioLevel(byte[] pcmData)
|
||
{
|
||
if (pcmData == null || pcmData.Length == 0)
|
||
return 0.0f;
|
||
|
||
double rms = 0;
|
||
int sampleCount = pcmData.Length / 2; // 16位音频
|
||
|
||
for (int i = 0; i < sampleCount; i++)
|
||
{
|
||
short sample = BitConverter.ToInt16(pcmData, i * 2);
|
||
rms += sample * sample;
|
||
}
|
||
|
||
rms = Math.Sqrt(rms / sampleCount);
|
||
float level = (float)(rms / short.MaxValue);
|
||
|
||
// 限制在0-1范围
|
||
return Math.Max(0.0f, Math.Min(1.0f, level * 10)); // 放大10倍以便显示
|
||
}
|
||
|
||
private async Task Agent_OnMessageEvent(string type, string message)
|
||
{
|
||
if (type == "question")
|
||
{
|
||
QuestionMessae = message;
|
||
// 添加用户问题到聊天历史，但首先检查是否已经存在相同内容的用户消息
|
||
if (ChatHistory.Count == 0 || ChatHistory.Last().Content != message || !ChatHistory.Last().IsUser)
|
||
{
|
||
ChatHistory.Add(new ChatMessage(message, true));
|
||
}
|
||
}
|
||
else if (type == "answer")
|
||
{
|
||
AnswerMessae = message;
|
||
// 添加AI回答到聊天历史
|
||
if (ChatHistory.Count > 0 && !ChatHistory.Last().IsUser)
|
||
{
|
||
// 如果最后一条消息是AI的，更新它
|
||
ChatHistory.Last().Content = message;
|
||
}
|
||
else
|
||
{
|
||
// 否则添加新的AI消息
|
||
ChatHistory.Add(new ChatMessage(message, false));
|
||
}
|
||
}
|
||
else if (type == "emotion")
|
||
{
|
||
Emotion = message;
|
||
}
|
||
else if (type == "answer_stop")
|
||
{
|
||
// TTS播放结束，触发音频服务的冷却期
|
||
if (_agent.AudioService != null && DeviceInfo.Platform == DevicePlatform.Android)
|
||
{
|
||
var audioService = _agent.AudioService as Services.AudioService;
|
||
audioService?.StopPlaying(); // 这会触发冷却期
|
||
|
||
// 添加新逻辑：在冷却期结束后，自动启动新一轮录音
|
||
_ = Task.Run(async () =>
|
||
{
|
||
// 等待冷却期结束(ttsCooldownTime+0.1秒额外缓冲)
|
||
await Task.Delay(TimeSpan.FromSeconds(TtsCooldownTime + 0.1));
|
||
|
||
// 确保不在录音中
|
||
if (_agent != null && !_agent.IsRecording)
|
||
{
|
||
AddDebugLog("冷却期结束，自动开始新一轮录音");
|
||
await MainThread.InvokeOnMainThreadAsync(async () =>
|
||
{
|
||
try
|
||
{
|
||
await _agent.StartRecording("auto");
|
||
}
|
||
catch (Exception ex)
|
||
{
|
||
AddDebugLog($"自动开始录音失败: {ex.Message}");
|
||
}
|
||
});
|
||
}
|
||
});
|
||
}
|
||
}
|
||
// 处理MCP消息
|
||
else if (type == "mcp")
|
||
{
|
||
await HandleMcpMessage(message);
|
||
}
|
||
|
||
// 添加调试日志
|
||
if (IsDebugMode)
|
||
{
|
||
AddDebugLog($"[{type}] {message}");
|
||
}
|
||
}
|
||
|
||
private async Task Agent_OnOtaEvent(OtaResponse? otaResponse)
|
||
{
|
||
LastOtaCheckTime = DateTime.Now;
|
||
LatestOtaResponse = otaResponse;
|
||
|
||
if (otaResponse != null)
|
||
{
|
||
OtaStatus = "检查成功";
|
||
|
||
// 提取激活信息
|
||
if (otaResponse.Activation != null)
|
||
{
|
||
ActivationCode = otaResponse.Activation.Code;
|
||
ActivationMessage = otaResponse.Activation.Message;
|
||
}
|
||
|
||
// 提取固件信息
|
||
if (otaResponse.Firmware != null)
|
||
{
|
||
FirmwareVersion = otaResponse.Firmware.Version;
|
||
FirmwareUrl = otaResponse.Firmware.Url;
|
||
LatestVersion = FirmwareVersion;
|
||
|
||
// 比较版本
|
||
CompareVersions();
|
||
}
|
||
|
||
// 提取服务器时间
|
||
if (otaResponse.ServerTime != null)
|
||
{
|
||
ServerTime = DateTimeOffset.FromUnixTimeMilliseconds(otaResponse.ServerTime.Timestamp).DateTime;
|
||
}
|
||
|
||
// 提取MQTT信息
|
||
if (otaResponse.Mqtt != null)
|
||
{
|
||
MqttEndpoint = otaResponse.Mqtt.Endpoint;
|
||
}
|
||
|
||
// 如果WebSocket配置更新了，更新当前URL
|
||
if (otaResponse.WebSocket != null && !string.IsNullOrEmpty(otaResponse.WebSocket.Url))
|
||
{
|
||
ServerUrl = otaResponse.WebSocket.Url;
|
||
}
|
||
|
||
AddDebugLog($"OTA检查成功，激活码: {ActivationCode}");
|
||
|
||
if (!string.IsNullOrEmpty(FirmwareUrl))
|
||
{
|
||
AddDebugLog($"发现固件更新: {FirmwareVersion}");
|
||
}
|
||
}
|
||
else
|
||
{
|
||
OtaStatus = "检查失败";
|
||
AddDebugLog("OTA检查失败，使用默认配置");
|
||
}
|
||
}
|
||
|
||
private void AddDebugLog(string message)
|
||
{
|
||
var logMessage = $"[{DateTime.Now:HH:mm:ss}] {message}";
|
||
|
||
if (DebugLogs.Count >= 100) // 保持最新100条日志
|
||
{
|
||
DebugLogs.RemoveAt(0);
|
||
}
|
||
|
||
DebugLogs.Add(logMessage);
|
||
}
|
||
|
||
public void ClearDebugLogs()
|
||
{
|
||
DebugLogs.Clear();
|
||
}
|
||
|
||
/// <summary>
|
||
/// 清除聊天记录
|
||
/// </summary>
|
||
public void ClearChatHistory()
|
||
{
|
||
ChatHistory.Clear();
|
||
QuestionMessae = "";
|
||
AnswerMessae = "";
|
||
}
|
||
|
||
/// <summary>
|
||
/// 获取OTA更新状态信息
|
||
/// </summary>
|
||
/// <returns>包含当前版本、最新版本和更新状态的字符串</returns>
|
||
public string GetUpdateStatusInfo()
|
||
{
|
||
if (string.IsNullOrEmpty(LatestVersion))
|
||
{
|
||
return $"当前版本: {CurrentVersion}\n尚未检查更新";
|
||
}
|
||
|
||
if (NeedUpdate)
|
||
{
|
||
return $"当前版本: {CurrentVersion}\n最新版本: {LatestVersion}\n状态: 需要更新";
|
||
}
|
||
else
|
||
{
|
||
return $"当前版本: {CurrentVersion}\n最新版本: {LatestVersion}\n状态: 已是最新";
|
||
}
|
||
}
|
||
|
||
// 版本比较方法
|
||
private void CompareVersions()
|
||
{
|
||
try
|
||
{
|
||
if (string.IsNullOrEmpty(LatestVersion))
|
||
{
|
||
NeedUpdate = false;
|
||
UpdateMessage = "无法获取最新版本信息";
|
||
return;
|
||
}
|
||
|
||
// 解析版本号
|
||
var currentParts = CurrentVersion.Split('.');
|
||
var latestParts = LatestVersion.Split('.');
|
||
|
||
// 比较主版本号、次版本号、修订号
|
||
for (int i = 0; i < Math.Min(currentParts.Length, latestParts.Length); i++)
|
||
{
|
||
if (int.TryParse(currentParts[i], out int current) &&
|
||
int.TryParse(latestParts[i], out int latest))
|
||
{
|
||
if (latest > current)
|
||
{
|
||
NeedUpdate = true;
|
||
UpdateMessage = $"发现新版本！当前版本: {CurrentVersion}，最新版本: {LatestVersion}";
|
||
AddDebugLog(UpdateMessage);
|
||
return;
|
||
}
|
||
else if (latest < current)
|
||
{
|
||
NeedUpdate = false;
|
||
UpdateMessage = $"当前版本已是最新（当前: {CurrentVersion}，服务器: {LatestVersion}）";
|
||
return;
|
||
}
|
||
}
|
||
}
|
||
|
||
// 如果版本号位数不同
|
||
if (latestParts.Length > currentParts.Length)
|
||
{
|
||
NeedUpdate = true;
|
||
UpdateMessage = $"发现新版本！当前版本: {CurrentVersion}，最新版本: {LatestVersion}";
|
||
}
|
||
else
|
||
{
|
||
NeedUpdate = false;
|
||
UpdateMessage = $"当前版本已是最新（{CurrentVersion}）";
|
||
}
|
||
|
||
AddDebugLog(UpdateMessage);
|
||
}
|
||
catch (Exception ex)
|
||
{
|
||
AddDebugLog($"版本比较失败: {ex.Message}");
|
||
NeedUpdate = false;
|
||
UpdateMessage = "版本比较失败";
|
||
}
|
||
}
|
||
|
||
public async Task ManualOtaCheck()
|
||
{
|
||
try
|
||
{
|
||
OtaStatus = "检查中...";
|
||
AddDebugLog("开始手动OTA检查");
|
||
|
||
// 确保设置当前版本
|
||
_agent.CurrentVersion = CurrentVersion;
|
||
|
||
var result = await _agent.CheckOtaUpdate();
|
||
|
||
if (result != null)
|
||
{
|
||
AddDebugLog("手动OTA检查成功");
|
||
|
||
// 显示版本比较结果
|
||
if (NeedUpdate)
|
||
{
|
||
AddDebugLog($"【版本信息】{UpdateMessage}");
|
||
if (!string.IsNullOrEmpty(FirmwareUrl))
|
||
{
|
||
AddDebugLog($"【更新地址】{FirmwareUrl}");
|
||
}
|
||
}
|
||
else
|
||
{
|
||
AddDebugLog($"【版本信息】{UpdateMessage}");
|
||
}
|
||
}
|
||
else
|
||
{
|
||
AddDebugLog("手动OTA检查失败");
|
||
}
|
||
}
|
||
catch (Exception ex)
|
||
{
|
||
OtaStatus = "检查异常";
|
||
AddDebugLog($"OTA检查异常: {ex.Message}");
|
||
}
|
||
}
|
||
|
||
// 处理MCP消息
|
||
private async Task HandleMcpMessage(string message)
|
||
{
|
||
try
|
||
{
|
||
AddDebugLog($"收到MCP消息: {message}");
|
||
|
||
if (_mcpClient == null)
|
||
{
|
||
var clientTransport = new StreamClientTransport(
|
||
serverInput: _clientToServerPipe.Writer.AsStream(),
|
||
serverOutput: _serverToClientPipe.Reader.AsStream());
|
||
|
||
_mcpClient = await McpClientFactory.CreateAsync(clientTransport);
|
||
AddDebugLog("MCP客户端初始化成功");
|
||
}
|
||
|
||
dynamic? mcp = Newtonsoft.Json.JsonConvert.DeserializeObject<dynamic>(message);
|
||
if (mcp == null)
|
||
{
|
||
AddDebugLog("MCP消息解析失败");
|
||
return;
|
||
}
|
||
|
||
if (mcp.method == "initialize")
|
||
{
|
||
// 处理初始化请求
|
||
var resultData = new
|
||
{
|
||
protocolVersion = "2024-11-05",
|
||
capabilities = _mcpClient.ServerCapabilities,
|
||
serverInfo = new
|
||
{
|
||
name = "XiaoZhiSharp MAUI",
|
||
version = CurrentVersion
|
||
}
|
||
};
|
||
|
||
JsonNode resultNode = JsonSerializer.SerializeToNode(resultData);
|
||
JsonRpcResponse? response = new JsonRpcResponse()
|
||
{
|
||
Id = new RequestId((long)mcp.id),
|
||
JsonRpc = "2.0",
|
||
Result = resultNode
|
||
};
|
||
|
||
await _agent.McpMessage(JsonSerializer.Serialize(response));
|
||
AddDebugLog("已响应MCP初始化请求");
|
||
}
|
||
else if (mcp.method == "tools/list")
|
||
{
|
||
// 处理工具列表请求
|
||
var tools = await _mcpClient.ListToolsAsync();
|
||
List<Tool> toolsList = new List<Tool>();
|
||
foreach (var item in tools)
|
||
{
|
||
toolsList.Add(item.ProtocolTool);
|
||
}
|
||
|
||
var resultData = new
|
||
{
|
||
tools = toolsList
|
||
};
|
||
|
||
JsonNode resultNode = JsonSerializer.SerializeToNode(resultData);
|
||
JsonRpcResponse? response = new JsonRpcResponse()
|
||
{
|
||
Id = new RequestId((long)mcp.id),
|
||
JsonRpc = "2.0",
|
||
Result = resultNode
|
||
};
|
||
|
||
var options = new JsonSerializerOptions
|
||
{
|
||
Encoder = JavaScriptEncoder.UnsafeRelaxedJsonEscaping
|
||
};
|
||
|
||
await _agent.McpMessage(JsonSerializer.Serialize(response, options));
|
||
AddDebugLog("已响应MCP工具列表请求");
|
||
}
|
||
else if (mcp.method == "tools/call")
|
||
{
|
||
// 处理工具调用请求
|
||
JsonNode? root = JsonNode.Parse(message);
|
||
|
||
string? name = root?["params"]?["name"]?.GetValue<string>();
|
||
JsonNode? argumentsNode = root?["params"]?["arguments"];
|
||
|
||
Dictionary<string, object>? arguments = null;
|
||
if (argumentsNode != null)
|
||
{
|
||
arguments = argumentsNode.Deserialize<Dictionary<string, object>>();
|
||
}
|
||
|
||
AddDebugLog($"调用工具: {name}, 参数: {argumentsNode}");
|
||
|
||
CallToolResponse? callToolResponse = await _mcpClient.CallToolAsync(name, arguments);
|
||
JsonNode jsonNode = JsonSerializer.SerializeToNode(callToolResponse);
|
||
JsonRpcResponse? response = new JsonRpcResponse()
|
||
{
|
||
Id = new RequestId((long)mcp.id),
|
||
JsonRpc = "2.0",
|
||
Result = jsonNode
|
||
};
|
||
|
||
var options = new JsonSerializerOptions
|
||
{
|
||
Encoder = JavaScriptEncoder.UnsafeRelaxedJsonEscaping
|
||
};
|
||
await _agent.McpMessage(JsonSerializer.Serialize(response, options));
|
||
AddDebugLog("已响应MCP工具调用请求");
|
||
}
|
||
}
|
||
catch (Exception ex)
|
||
{
|
||
AddDebugLog($"处理MCP消息出错: {ex.Message}");
|
||
}
|
||
}
|
||
|
||
/// <summary>
|
||
/// 启动连接状态监测定时器
|
||
/// </summary>
|
||
private void StartConnectionMonitor()
|
||
{
|
||
if (_connectionMonitorTimer != null)
|
||
{
|
||
_connectionMonitorTimer.Stop();
|
||
_connectionMonitorTimer.Dispose();
|
||
}
|
||
|
||
_connectionMonitorTimer = new System.Timers.Timer(2000); // 每2秒检查一次
|
||
_connectionMonitorTimer.Elapsed += async (sender, e) => await CheckConnectionStatus();
|
||
_connectionMonitorTimer.AutoReset = true;
|
||
_connectionMonitorTimer.Start();
|
||
|
||
AddDebugLog("启动连接状态监测");
|
||
}
|
||
|
||
/// <summary>
|
||
/// 检查连接状态并在必要时重连
|
||
/// </summary>
|
||
private async Task CheckConnectionStatus()
|
||
{
|
||
try
|
||
{
|
||
bool wasConnected = IsConnected;
|
||
IsConnected = _agent.ConnectState == WebSocketState.Open;
|
||
|
||
// 如果连接状态发生变化
|
||
if (IsConnected != wasConnected)
|
||
{
|
||
await MainThread.InvokeOnMainThreadAsync(() => {
|
||
if (IsConnected)
|
||
{
|
||
AddDebugLog("连接状态: 已连接");
|
||
_reconnectAttempts = 0; // 连接成功，重置重连尝试计数
|
||
|
||
// 重连成功后，彻底重置音频服务和VAD状态
|
||
if (_agent.AudioService != null && DeviceInfo.Platform == DevicePlatform.Android)
|
||
{
|
||
var audioService = _agent.AudioService as Services.AudioService;
|
||
if (audioService != null)
|
||
{
|
||
// 停止任何可能在进行的录音
|
||
if (audioService.IsRecording)
|
||
{
|
||
audioService.StopRecording();
|
||
}
|
||
|
||
// 确保不在播放状态
|
||
if (audioService.IsPlaying)
|
||
{
|
||
audioService.StopPlaying();
|
||
}
|
||
|
||
// 重置VAD参数和状态
|
||
//audioService.ConfigureVAD(UseVAD, VadEnergyThreshold, VadSilenceFrames, TtsCooldownTime);
|
||
//audioService.ResetTtsState(); // 特别重置TTS状态
|
||
AddDebugLog("重连成功，已重置音频服务和VAD参数");
|
||
|
||
// 延迟一秒后尝试开始新的录音会话
|
||
_ = Task.Run(async () =>
|
||
{
|
||
await Task.Delay(1000);
|
||
await MainThread.InvokeOnMainThreadAsync(async () =>
|
||
{
|
||
try
|
||
{
|
||
if (!_agent.IsRecording)
|
||
{
|
||
AddDebugLog("重连后开始新一轮录音");
|
||
await _agent.StartRecording("auto");
|
||
}
|
||
}
|
||
catch (Exception ex)
|
||
{
|
||
AddDebugLog($"重连后开始录音失败: {ex.Message}");
|
||
}
|
||
});
|
||
});
|
||
}
|
||
}
|
||
}
|
||
else
|
||
{
|
||
AddDebugLog("连接状态: 已断开");
|
||
|
||
// 断线时停止任何录音
|
||
if (_agent.IsRecording)
|
||
{
|
||
_ = _agent.StopRecording();
|
||
AddDebugLog("断线检测，已停止录音");
|
||
}
|
||
}
|
||
});
|
||
}
|
||
|
||
// 如果断开连接，尝试重连
|
||
if (!IsConnected &&
|
||
(DateTime.Now - _lastReconnectAttempt).TotalMilliseconds > ReconnectInterval &&
|
||
_reconnectAttempts < MaxReconnectAttempts)
|
||
{
|
||
_lastReconnectAttempt = DateTime.Now;
|
||
_reconnectAttempts++;
|
||
|
||
await MainThread.InvokeOnMainThreadAsync(async () => {
|
||
AddDebugLog($"尝试重新连接... (第{_reconnectAttempts}次)");
|
||
try
|
||
{
|
||
await _agent.Restart();
|
||
}
|
||
catch (Exception ex)
|
||
{
|
||
AddDebugLog($"重新连接失败: {ex.Message}");
|
||
}
|
||
});
|
||
}
|
||
|
||
// 如果多次尝试重连都失败，暂停一段时间后重试
|
||
if (!IsConnected && _reconnectAttempts >= MaxReconnectAttempts &&
|
||
(DateTime.Now - _lastReconnectAttempt).TotalSeconds > 30)
|
||
{
|
||
_reconnectAttempts = 0; // 重置尝试次数，进入新一轮尝试
|
||
}
|
||
}
|
||
catch (Exception ex)
|
||
{
|
||
AddDebugLog($"连接监测异常: {ex.Message}");
|
||
}
|
||
}
|
||
|
||
/// <summary>
|
||
/// 释放资源，确保应用程序关闭时能够正确释放所有资源
|
||
/// </summary>
|
||
public void Dispose()
|
||
{
|
||
if (!_disposed)
|
||
{
|
||
_disposed = true;
|
||
|
||
// 释放连接监测定时器
|
||
if (_connectionMonitorTimer != null)
|
||
{
|
||
_connectionMonitorTimer.Stop();
|
||
_connectionMonitorTimer.Dispose();
|
||
_connectionMonitorTimer = null;
|
||
}
|
||
|
||
// 停止MCP服务
|
||
_host?.StopAsync().Wait();
|
||
_host?.Dispose();
|
||
|
||
// 释放其他资源
|
||
_agent?.Dispose();
|
||
|
||
// 标记为已释放
|
||
GC.SuppressFinalize(this);
|
||
}
|
||
}
|
||
}
|
||
}
|