0

我有一个功能齐全的 IBM Watson Speech To Text 客户端。我想开始记录更多元数据（单词置信度、开始/结束时间等），所以我在我的初始请求中添加了适当的字段。

一切都很顺利，直到我遇到将 Watson 文本消息响应反序列化为 JSON 对象的异常。当我打印字符串时，这就是结果。注意它被切断了，这解释了反序列化的错误：

{
   "results": [
      {
         "word_alternatives": [
            {
               "start_time": 3.71,
               "alternatives": [
                  {
                     "confidence": 1.0,
                     "word": "Hey"
                  }
               ],
               "end_time": 3.97
            },
            {
               "start_time": 3.97,
               "alternatives": [
                  {
                     "confidence": 1.0,
                     "word": "what's"
                  }
               ],
               "end_time": 4.54
            },
            {
               "start_time": 4.54,
               "alternatives": [
                  {
                     "confidence": 1.0,

看来我要求的信息太多了。从返回的System.Net.WebSockets.WebSocketReceiveResult对象ClientWebSocket.ReceiveAsync()具有result.Count描述发送的信息字节数的属性。在调试中我发现result.Count = 1024.

我的问题是：

1 - Watson 施加的 1kB 限制还是 .NET WebSocket 库的限制？

2 - 如何解除限制以接收完整消息？

编辑：最小的例子

有很多代码涉及到这个问题，但希望这能提供足够的上下文来帮助：

    // Set up connection
    ClientWebSocket socket = new ClientWebSocket();
    // Works: 
    //string headerInfo = "{ \"content-type\":\"audio/l16;rate=8000\",\"interim_results\":true,\"smart_formatting\":true,\"timestamps\":false,\"inactivity_timeout\":-1,\"word_confidence\":false,\"profanity_filter\":false,\"action\":\"start\"}";
    // Doesn't:
    string headerInfo = "{ \"content-type\":\"audio/l16;rate=8000\",\"interim_results\":true,\"smart_formatting\":true,\"timestamps\":true,\"inactivity_timeout\":-1,\"word_confidence\":true,\"profanity_filter\":false,\"action\":\"start\"}";
    var startMsg = new ArraySegment<byte>(Encoding.UTF8.GetBytes(headerInfo));
    var endOfMsg = true;
    await socket.SendAsync(startMsg, WebSocketMessageType.Text, endOfMsg, default(CancellationToken));

    // Send Audio bytes

    // Receive response
    var msgBuffer = new byte[8 * 1024];
    var receiver = new ArraySegment<byte>(msgBuffer);
    var result = await socket.ReceiveAsync(receiver, CancellationToken.None);
    var message = Encoding.UTF8.GetString(receiver.Array.Take(result.Count).ToArray());
    var result = JsonConvert.DeserializeObject<ResultsObject>(watsonMsg);

ResultsObject是要反序列化的本地类型。

4

1 回答 1

0

事实证明，一条消息是分几块发送的。解决方案是这个修复：

var ResultMsg = new List<byte>();
if (receiver.Array.Length > 0)
{
    ResultMsg.AddRange(receiver.Array.Take(result.Count));
}
if (result.EndOfMessage)
{
    var msgBytes = ResultMsg.ToArray();
    var message = Encoding.UTF8.GetString(msgBytes);
    TextMessageHandler(message);
    ResultMsg.Clear();
}
于 2018-08-31T21:10:17.097 回答