问题是你的serviceUrl——它不应该是指向你自己服务的链接——它应该是特定会话的唯一serviceUrl。团队根据租户所在地（例如北美的“NAM”）有一些这样的功能。您需要为您的对话获取一个特定的，就像您得到conversationId一样。如果不熟悉您使用的这个特定示例，我想它是'coordinate-logger'项目的一部分。 ServiceUrl应该如下所示：https://smba.trafficmanager.net/emea/或https://smba.trafficmanager.net/nam/或类似的。 为了解释为什么这一点很重要，你可能会发现读一篇我写的关于电话如何工作的博客文章是值得的。它没有讨论主动式消息传递本身，但它仍然是相关的。见https://hilton.giesenow.com/how-bot-calls-actually-work。 [更新：添加一些格式示例]会话id根据会话类型（1-1、群聊或团队频道）看起来有点不同，但它应该类似于以下其中之一： 1-1聊天：a:1gUrQbVe1BjcpZePQ6m.......[long值] 群聊：19:0a5b1b32cc54402[其他bits]@thread.v2 频道：19:ac23ff62cc54402[其他bits]@thread.skype

您可以提供自己的KeyManager实现（稍后称为实际的KeyManager）。如果调用getPrivateKey（），您就知道服务器已请求客户端证书。

当通过socket.io发出事件时，必须在数据之前定义事件名称。例子： exports.getAll = function(req, res){ var io = req.app.get("socketio"); io.emit("message", "hi!");} 现在您将能够从客户端接收message事件。 Reference: https://socket.io/docs/v4/emitting-events/

不要使用任何low-level套接字库，如TcpListener或System.Net.Sockets，除非您正在尝试学习套接字编程或进行学校项目。有大量的well-supported.NET库用于进行client-server通信，它们为您处理低级套接字和multi-threading，因此您可以专注于您的业务规则。 最终服务器将在IIS上运行吗？如果是，请研究使用信号器。它支持客户端和服务器，并且在服务器端具有高级用户管理，因此服务器可以根据自定义条件向单个客户端或整个组发送回复或数据。 如果您不能使用IIS，请尝试NetCoreServer，它具有异步客户端和服务器功能，并且有使用TCP、UDP、HTTP和WebSocket的示例。 还有其他多个库需要考虑。如果您决定使用套接字，请查看此答案中的列表。 Update 由于这是一个需要socket编程的学校项目，因此您可以执行以下操作。 Server 使用类似于ConcurrectDictionary的tread-safe集合来存储连接的客户端 每个客户机对象将使用events从其客户机接收数据并检测客户机断开连接 服务器将订阅这些事件，并在收到消息时执行其所需的任何操作 当服务器执行任何客户端操作（如发送消息）时，它需要lock该操作以避免死锁 当客户端断开连接时，请确保取消订阅此客户端的所有订阅，以避免内存泄漏 这是一个很好

编辑：您可以动态地设置结构的格式字符串。下面是一个简单的例子： str1 = b"Yes"str2 = b"No"msg_packed1 = struct.Struct("{}s".format(len(str1))).pack(str1)msg_packed2 = struct.Struct("{}s".format(len(str2))).pack(str2) 在你的例子中 reply_packed = struct.Struct("{}s I".format(len(reply[0]))).pack(*reply) 我是从使用python中的struct模块打包和解包可变长度的array/string得到这个想法的

默认情况下，DNS查询超时为5秒（默认查询超时），但如果需要，可以自定义下划线NettyHttpClient HttpClient httpClient = HttpClient.create() .resolver(spec -> spec.queryTimeout(Duration.ofSeconds(10)));WebClient client = WebClient.builder() .clientConnector(new ReactorClientHttpConnector(httpClient)) .build();

从本文件中： 主机保持空闲连接打开的时间可能超过其指示的时间，但它应尝试保持连接的时间至少与指示的时间相同。 大写字母是关键，在文件中是这样写的： 你的案子符合“应该”的部分。例如，keep-alive是一个建议-但是如果服务器需要这些资源（或者被配置为打开的连接少于客户端的数量），可以随意关闭它们。您的客户将需要处理此状态。 如果所描述的行为取决于您打开的并行套接字的数量（除了超时），那么您很可能会在服务器上遇到资源限制—无论是显式配置的，还是默认值的隐式配置的。 想象一下，如果只需要两个keep-alive请求就可以使服务器提供的并发连接数饱和，那么DDOS攻击将多么容易。 还要注意，超时是基于服务器（从发送最后一个数据包开始）和客户端（从接收最后一个数据包开始）对时间的不同感知

我不喜欢这个示例的一点是，它使您似乎需要托管-ability，以便在与bot本身相同的web主机内进行pro-active调用，这绝对不是必需的。例如，您可以将bot托管在web应用程序中，但直接从Azure函数发出pro-active调用。这就是为什么我把一个不同的样本放在一起-看看这里。它只需要一个服务url（例如，因为端点可以根据租户的地理位置进行更改）和一个“会话id”，以便它知道要向哪个用户/组/通道发送消息。请检查一下，看是否有用。

“问题”在于服务器中的readLine()。 这是通缉犯的行为BufferedReader以某种方式实现readLine()，使其阻塞，直到它接收到以下任一项：'\n'、'\r'、回车符后跟换行符或EOF 客户机两个都没有发送。 您可以使用println()，而不是使用PrintWriter的print()方法。

问题是因为客户端中的stdin.readLineSync()阻止了当前的thread。您可以通过生成一个隔离来处理这部分代码来解决这个问题，这样它就不会阻止socket.listen从服务器打印响应。 请参阅下面更新的客户端代码： import 'dart:io';import 'dart:isolate';import 'dart:typed_data';void main() async { //gets the username String name = ''; while (name.isEmpty) { print('Enter your name: '); name = stdin.readLineSync() ?? ''; } // connect to the socket server final socket = await Socket.connect("192.168.0.112", 4000); print('Connected to: ${socket.remoteAddress.address}:${socket.remotePort}'); // listen for responses from the server socket.listen( // handle data from the server (Uint8List data) {

简言之，您不能重用HttpRequestMessage，它会处理大量在SendAsync级别无法缓解的问题（如流式内容等）。您需要在ExecuteAsynclambda中创建/重新创建HttpRequestMessage，或者更好地使用IHttpClientFactory，然后在HttpClientBuilder级别使用Polly。 重新创建HttpRequestMessage的示例 return await policy.ExecuteAsync(() =>{ // note the using here is a superfluous, but good practice using var requestMessage = new HttpRequestMessage(HttpMethod.Post, fullUrl) { Content = new StringContent(aString) }; requestMessage.Headers.Add("access_token", token); return client.SendAsync(requestMessage);}).ConfigureAwait(false); 然而，理想情况下，您应该将HttpClientFactory与类型化或命名的客户机一起使用 给定一个类型化的客户端 public clas

对于问题1（强制断开与客户端的连接），这应该是可行的 val flow: Flow[Message, Message, (Future[Done], Promise[Option[Message])] = Flow.fromSinkAndSourceMat( printSink, Source.maybe )(Keep.both)val (upgradeResponse, (closed, disconnect)) = Http().singleWebsocketRequest(WebSocketRequest("ws://localhost/ws"), flow) disconnect然后可以用None来断开连接： disconnect.success(None) 对于问题2，我的直觉是，这种动态流操作似乎需要一个自定义流操作符（即，一个级别低于图形DSL，两个级别低于“normal”scaladsl/javadsl）。老实说，我在那里没有太多的直接经验。

[更新，感谢@user207421的评论] 2 solutions 继续使用DataOutputStream.writeUTF然后你必须使用DataInputStream.readUTF而不是BufferedReader.readLine。如果要使用'\n'作为分隔符，则必须检测此类字符 继续使用BufferedReader.readLine然后您必须使用输出流方法，如Writer.write，而不是DataOutputStream.writeUTF。只使用一个BufferedReader实例，至少在服务器端（numString将保留对entrada实例不可用的缓冲数据）。对于UTF-8，请使用： BufferedReader in = new BufferedReader(new InputStreamReader(cs.getInputStream(), "UTF-8"));BufferedWriter out = new BufferedWriter(new OutputStreamWriter(cs.getOutputStream(), "UTF-8"));

TL；DR，请参阅下面的代码更正。 在提出任何问题之前，都需要关注以下几点： 将服务器的数据编码从UTF-16更改为UTF-8。为什么？任何端点之间的数据传输都依赖于consistency，即服务器/客户端应用程序的数据编码。当您的服务器（ServerSocketConnection）正在发送用UTF-16编码的消息时，您的客户端（__socket_reading_no_server）正在接收用UTF-8编码的消息。即使您的客户机能够接收来自服务器的所有消息，它也无法识别它们。例如，UTF-16将字符串"5"编码为字节[0,53]，对于UTF-8，结果是[53]（假设big-endian字节顺序）。有关更多详细信息，请参阅维基百科。 不要使用out.newLine()。改用out.write("\r\n")。为什么？newline()的行为是platform-dependent，这导致分别为Unix-like操作系统或Windows操作系统返回一个或两个字符。它依赖于line.separator系统属性，您可以参考Java文档了解更多详细信息。 您的data = s.recv(4)设置了一个约束，您的客户端一次最多读取4个字节，这很危险。为什么？因为根据Pythondoc，您的4不是客户端接收的实际字节数，而是要接收的最大数据量。此外，理论上，客户端最多只能接收下一条传入消息的99

这里有很多问题。 双工协议问题 line = dis.readUTF();dos.writeUTF(line); 这是行不通的；dis.readUTF()行将被阻塞（冻结），直到读取一行。问题是，有时候你没有东西要发送，在这种情况下你想读，而在这种情况下你没有东西要读，你想发送。实际上，你需要完全重新设计它；你需要2threads。此时，您将进入多核问题，需要为2threads之间共享的所有数据提供同步原语和/或java.util.concurrent类。 或者，采用一种严格的推或拉模式（在任何给定时间，双方都知道谁可以发送，如果另一方想发送，他们根本无法发送）。例如，每一方每秒发送一条简单的“无事可做”消息，每次都交换位置。当然，这是一种效率很低的算法。但可以在不涉及多个threads的情况下编写。 齐头并进 dos.writeUTF(line); 这实际上并没有发送任何东西，或者至少不能保证发送任何东西。要在互联网上发送任何数据，它都会被包装在一个具有大量开销的数据包中。所以，东西会被缓冲，直到有一个完整的数据包要发送。这意味着那条线什么都没用。它只是填满了一个缓冲区，没有数据包流出。你首先需要关闭或冲洗。dos.flush()也许会有帮助。这是一个大问题，因为以后你会： soc.close();dis.close();dos.close(); 首先关闭插座，然后关闭插座。然后