XFEExtension
【DLL】XFE各类拓展是一个C#的DLL库,旨在优化C#代码中常用语句的使用,并提供更简洁的访问方式,同时提供Xunit测试框架,快速搭建服务器/客户端,免费ChatGPTAPI接口,免费通讯服务器,XFE下载器,新增格式等
关注
0
Fork
0
Star
0
返回提交历史
Modified
XFE各类拓展/CyberComm.cs
+22
-24
XFEstudio/XFEExtension
修改所有发送消息方法的返回消息ID为是否成功
1aa96e6
代码差异
1 个文件
+22
-24
@@ -1175,12 +1175,11 @@ namespace XFE各类拓展.CyberComm
1175
1175
/// </summary>
1176
1176
/// <param name="message">待发送的文本</param>
1177
1177
/// <param name="timeout">最长超时时长</param>
1178
/// <returns>消息ID</returns>
1179
public async Task<string> SendTextMessage(string message, int timeout = 10000)
1178
/// <returns>服务器接收校验是否成功</returns>
1179
public async Task<bool> SendTextMessage(string message, int timeout = 10000)
1180
1180
{
1181
1181
var messageId = Guid.NewGuid().ToString();
1182
await SendTextMessage(message, messageId, timeout);
1183
return messageId;
1182
return await SendTextMessage(message, messageId, timeout);
1184
1183
}
1185
1184
/// <summary>
1186
1185
/// 发送文本消息
@@ -1189,8 +1188,8 @@ namespace XFE各类拓展.CyberComm
1189
1188
/// <param name="messageId">消息ID</param>
1190
1189
/// <param name="timeout">最长超时时长</param>
1191
1190
/// <exception cref="XFECyberCommException"></exception>
1192
/// <returns>服务器接收校验等待</returns>
1193
public async Task SendTextMessage(string message, string messageId, int timeout)
1191
/// <returns>服务器接收校验是否成功</returns>
1192
public async Task<bool> SendTextMessage(string message, string messageId, int timeout)
1194
1193
{
1195
1194
try
1196
1195
{
@@ -1201,7 +1200,7 @@ namespace XFE各类拓展.CyberComm
1201
1200
Task.Delay(timeout);
1202
1201
UpdateTaskTrigger?.Invoke(false, messageId);
1203
1202
});
1204
await new XFEWaitTask<bool>(ref UpdateTaskTrigger, messageId);
1203
return await new XFEWaitTask<bool>(ref UpdateTaskTrigger, messageId);
1205
1204
}
1206
1205
catch (Exception ex)
1207
1206
{
@@ -1214,9 +1213,9 @@ namespace XFE各类拓展.CyberComm
1214
1213
/// <param name="role">发送者角色</param>
1215
1214
/// <param name="message">待发送的文本</param>
1216
1215
/// <exception cref="XFECyberCommException"></exception>
1217
/// <returns>消息ID</returns>
1216
/// <returns>服务器接收校验是否成功</returns>
1218
1217
[Obsolete("发送者已统一,请使用SendTextMessage或SendBinaryTextMessage")]
1219
public async Task<string> SendStandardTextMessage(string role, string message)
1218
public async Task<bool> SendStandardTextMessage(string role, string message)
1220
1219
{
1221
1220
try
1222
1221
{
@@ -1233,12 +1232,11 @@ namespace XFE各类拓展.CyberComm
1233
1232
/// <param name="message">二进制消息</param>
1234
1233
/// <param name="signature">签名标识</param>
1235
1234
/// <param name="timeout">最长超时时长</param>
1236
/// <returns></returns>
1237
public async Task<string> SendSignedBinaryMessage(byte[] message, string signature, int timeout = 10000)
1235
/// <returns>服务器接收校验是否成功</returns>
1236
public async Task<bool> SendSignedBinaryMessage(byte[] message, string signature, int timeout = 10000)
1238
1237
{
1239
1238
var messageId = Guid.NewGuid().ToString();
1240
await SendSignedBinaryMessage(message, messageId, signature, timeout);
1241
return messageId;
1239
return await SendSignedBinaryMessage(message, messageId, signature, timeout);
1242
1240
}
1243
1241
/// <summary>
1244
1242
/// 发送签名二进制消息
@@ -1247,9 +1245,9 @@ namespace XFE各类拓展.CyberComm
1247
1245
/// <param name="messageId">消息ID</param>
1248
1246
/// <param name="signature">签名标识</param>
1249
1247
/// <param name="timeout">最长超时时长</param>
1250
/// <returns>服务器接收校验等待</returns>
1248
/// <returns>服务器接收校验是否成功</returns>
1251
1249
/// <exception cref="XFECyberCommException"></exception>
1252
public async Task SendSignedBinaryMessage(byte[] message, string messageId, string signature, int timeout)
1250
public async Task<bool> SendSignedBinaryMessage(byte[] message, string messageId, string signature, int timeout)
1253
1251
{
1254
1252
try
1255
1253
{
@@ -1260,7 +1258,7 @@ namespace XFE各类拓展.CyberComm
1260
1258
Task.Delay(timeout);
1261
1259
UpdateTaskTrigger?.Invoke(false, messageId);
1262
1260
});
1263
await new XFEWaitTask<bool>(ref UpdateTaskTrigger, messageId);
1261
return await new XFEWaitTask<bool>(ref UpdateTaskTrigger, messageId);
1264
1262
}
1265
1263
catch (Exception ex)
1266
1264
{
@@ -1271,9 +1269,9 @@ namespace XFE各类拓展.CyberComm
1271
1269
/// 发送二进制文本消息
1272
1270
/// </summary>
1273
1271
/// <param name="message">消息</param>
1274
/// <returns>消息ID</returns>
1272
/// <returns>服务器接收校验是否成功</returns>
1275
1273
/// <exception cref="XFECyberCommException"></exception>
1276
public async Task<string> SendBinaryTextMessage(string message)
1274
public async Task<bool> SendBinaryTextMessage(string message)
1277
1275
{
1278
1276
try
1279
1277
{
@@ -1290,8 +1288,8 @@ namespace XFE各类拓展.CyberComm
1290
1288
/// <param name="message">待发送的二进制数据</param>
1291
1289
/// <param name="timeout">最长超时时长</param>
1292
1290
/// <exception cref="XFECyberCommException"></exception>
1293
/// <returns>消息ID</returns>
1294
public async Task<string> SendBinaryMessage(byte[] message, int timeout = 1000)
1291
/// <returns>服务器接收校验是否成功</returns>
1292
public async Task<bool> SendBinaryMessage(byte[] message, int timeout = 1000)
1295
1293
{
1296
1294
try
1297
1295
{
@@ -1306,9 +1304,9 @@ namespace XFE各类拓展.CyberComm
1306
1304
/// 发送图片
1307
1305
/// </summary>
1308
1306
/// <param name="filePath">图片路径</param>
1309
/// <returns>消息ID</returns>
1307
/// <returns>服务器接收校验是否成功</returns>
1310
1308
/// <exception cref="XFECyberCommException"></exception>
1311
public async Task<string> SendImage(string filePath)
1309
public async Task<bool> SendImage(string filePath)
1312
1310
{
1313
1311
try
1314
1312
{
@@ -1323,9 +1321,9 @@ namespace XFE各类拓展.CyberComm
1323
1321
/// 发送音频
1324
1322
/// </summary>
1325
1323
/// <param name="buffer">二进制音频流</param>
1326
/// <returns>消息ID</returns>
1324
/// <returns>服务器接收校验是否成功</returns>
1327
1325
/// <exception cref="XFECyberCommException"></exception>
1328
public async Task<string> SendAudioBuffer(byte[] buffer)
1326
public async Task<bool> SendAudioBuffer(byte[] buffer)
1329
1327
{
1330
1328
try
1331
1329
{