监视套接字以获取新数据然后处理该数据的最佳方法是什么? - c#

请原谅我的C#.Net新手身份。如果这很明显,但我从文档中错过了它,则可以访问相关页面或示例代码的链接。

我正在开发一个将接受来自Java应用程序的TCP套接字连接的应用程序。 (是的,在那部分上需要Java。这是Sun SPOT设备,Java是唯一的选择。)Java应用程序将定期将新数据写入套接字,而我的应用程序的工作是获取byte [],进行转换。将其转换为字符串,处理数据(更新UI等),然后将数据转发到另一台运行类似C#.NET应用程序的计算机上。

到目前为止,这是我做的事情:现在,应用程序在启动时旋转了一个线程,该线程打开了一个套接字。 Java应用程序可以成功连接到套接字,从而可以正常工作。我正在查看NetworkStream的beginRead方法以及dataAvailablelengthCanRead属性,但是我不确定如何确定何时读取一个数据包(通常约为512字节),但是可能会有所不同。

如果Java应用程序将数据写入流或存在积压的数据(Java应用程序将很快传递数据。)如何确保我一次只读取一个数据包?如果Java应用程序null在写入时终止了数据,这会有所帮助吗?够了吗

最后,套接字将仅接收一个连接,但是我需要保持打开状态直到出现错误或连接终止。处理这方面最优雅的方法是什么?我不认为关闭和重新打开每个数据包都会起作用,因为在Sun SPOT基站上运行的Java应用程序具有快速启动(几乎实时)的作用。现在,当基站终止时,我的应用程序死于大声痛苦的死亡。 🙂

感谢您的阅读和提供的任何帮助。

参考方案

“如果Java应用程序将数据写入流中,或者存在积压的数据(Java应用程序将相当快地传递数据。)如何确保我一次只读取一个数据包?”

注意不要假定您可以控制哪些数据最终存储在哪个数据包中。如果尝试发送字节数据{ 'H', 'e', 'l', 'l', 'o' },则不能保证所有这些数据都将在单个数据包中发送。虽然极不可能,但每个数据包可能仅包含一个字节,因此您将在5个不同的事件中接收所有五个字节。关键是,不要以这种方式依赖数据包。而是定义您自己的消息结束符,然后将所有传入的数据简单地扔入某种字节缓冲区中,并使用另一个函数来检测是否存在这些终结符。如果是这样,请阅读该终止符。举例来说,假设您两次从Java应用程序调用各自的send方法,其中包含以下数据:

{ 'H', 'e', 'l', 'l', 'o', '\0' }
{ 'W', 'o', 'r', 'l', 'd', '\0' }

应该如何准备您的应用程序以接收数据应该是这样的:

Server receives { 'H', 'e', 'l' }
Data stored in byte buffer { 'H', 'e', 'l' }
Check byte buffer for message terminator '\0'. None found. Buffer unchanged, no message processed.
Server receives { 'l', 'o', '\0', 'W' }
Data stored in byte buffer { 'H', 'e', 'l', 'l', 'o', '\0', 'W' }
Check byte buffer for message terminator '\0'. 1 found, extracted message { 'H', 'e', 'l', 'l', 'o' } and buffer updated { 'W' }

因此,尽管这并不是您最初问题的完全答案,但我认为它应该为您提供正确方向的推动。

您可能会遇到的一件事是,根本没有任何字符不能成为数据,而不是消息终止符。例如,许多文件包含数据\ 0,因此它们会破坏您的邮件检测。通常是通过为协议创建标头规范并检测是否期望标头(在这种情况下,寻找\ 0表示消息的结尾)还是在等待一定量的标头来解决此问题数据(可以由接收到的最后一个标头指定。)如果这没有意义,并且您认为您可能需要使用此技术,请告诉我,我将在此答案中补充说明。

将字符串分配给numpy.zeros数组[重复] - python

This question already has answers here: Weird behaviour initializing a numpy array of string data                                                                    (4个答案)         …

R'relaimpo'软件包的Python端口 - python

我需要计算Lindeman-Merenda-Gold(LMG)分数,以进行回归分析。我发现R语言的relaimpo包下有该文件。不幸的是,我对R没有任何经验。我检查了互联网,但找不到。这个程序包有python端口吗?如果不存在,是否可以通过python使用该包? python参考方案 最近,我遇到了pingouin库。

如何用'-'解析字符串到节点js本地脚本? - python

我正在使用本地节点js脚本来处理字符串。我陷入了将'-'字符串解析为本地节点js脚本的问题。render.js:#! /usr/bin/env -S node -r esm let argv = require('yargs') .usage('$0 [string]') .argv; console.log(argv…

如果我得到url(''),我该如何使用另一个URL - javascript

我是新手,正在写这篇文章,但是如果源上没有图像,那么我只有空白。有人可以告诉我,如果我正在获取背景图像,如何获取/images/no-image.jpg:url();这是我的代码:<div class="uk-clearfix uk-position-relative"> <div class="recipeb…

Matplotlib'粗体'字体 - python

跟随this example:import numpy as np import matplotlib.pyplot as plt fig = plt.figure() for i, label in enumerate(('A', 'B', 'C', 'D')): ax = f…