ping pong 관련 예외처리 추가
This commit is contained in:
@@ -317,12 +317,23 @@ namespace BitgetAPI.WebService
|
||||
|
||||
//Thread.Sleep(100);
|
||||
|
||||
byte[] buffer = new byte[4096 * 10];
|
||||
byte[] buffer = new byte[1024];
|
||||
WebSocketReceiveResult result = await webSocket.ReceiveAsync(new ArraySegment<byte>(buffer), CancellationToken.None);
|
||||
message = "";
|
||||
// 수신한 데이터 처리
|
||||
message = System.Text.Encoding.UTF8.GetString(buffer, 0, result.Count);
|
||||
|
||||
if (message.Contains("pong"))
|
||||
{
|
||||
string[] splitStr = { "pong" };
|
||||
var temp = message.Split(splitStr, StringSplitOptions.RemoveEmptyEntries);
|
||||
message = "";
|
||||
foreach (var item in temp)
|
||||
{
|
||||
message += item;
|
||||
}
|
||||
}
|
||||
|
||||
if (tempStrData == "") {
|
||||
if (!ValidateJSON(message))
|
||||
{
|
||||
@@ -340,6 +351,7 @@ namespace BitgetAPI.WebService
|
||||
else
|
||||
{
|
||||
message = tempStrData;
|
||||
tempStrData = "";
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
Reference in New Issue
Block a user