- android - RelativeLayout 背景可绘制重叠内容
- android - 如何链接 cpufeatures lib 以获取 native android 库?
- java - OnItemClickListener 不起作用,但 OnLongItemClickListener 在自定义 ListView 中起作用
- java - Android 文件转字符串
遇到以下问题。从文本文件中读取数据。每 40 毫秒向服务器发送一次数据。服务器必须将数据读入单独流中的无限循环。但这并没有发生。怎么了?
客户:
class Client
{
private TcpClient _client;
private Stream _stream;
private Boolean _isConnected;
private double[] _values;
public Client(String ipAddress, int portNum)
{
_client = new TcpClient();
_client.Connect(ipAddress, portNum);
}
public void SendValues(double[] values)
{
_values = values;
HandleCommunication();
}
public void HandleCommunication()
{
_isConnected = true;
_stream = _client.GetStream();
var dataBytes = new List<byte>();
foreach (double value in _values)
{
dataBytes.AddRange(BitConverter.GetBytes(value));
}
_client.SendBufferSize = _values.Length * sizeof(double);
_stream.Write(dataBytes.ToArray(), 0, _client.SendBufferSize);
Console.Write("Sending...");
_stream.Flush();
}
发送数据:
public partial class MainWindow : Window
{
private double[] values;
private System.Timers.Timer timer = new System.Timers.Timer(40);
Client _client = new Client("127.0.0.1", 55443);
public MainWindow()
{
InitializeComponent();
OpenSrcFile();
timer.Elapsed += TimerOnElapsed;
timer.Enabled = true;
}
private void TimerOnElapsed(object sender, ElapsedEventArgs e)
{
Console.WriteLine("is sending...");
_client.SendValues(values);
}
public void OpenSrcFile()
{
List<string> lines = File.ReadAllLines(@"file.txt").ToList();
string r = lines[0];
int sizeX = int.Parse(lines[1]);
lines.RemoveRange(0, 2);
values = GetValues(lines.ToArray());
}
private double[] GetValues(string[] lines)
{
return lines.Select(line => double.Parse(line.Replace(" ", ""), CultureInfo.InvariantCulture)).ToArray();
}
服务器:
class Server
{
private TcpListener _server;
private Boolean _isRunning;
public Server(int port)
{
_server = new TcpListener(IPAddress.Parse("127.0.0.1"), port);
_server.Start();
_isRunning = true;
}
public double[] GetData()
{
// wait for client connection
TcpClient client = _server.AcceptTcpClient();
Console.WriteLine("Connected!");
var stream = client.GetStream();
byte[] buffer = new byte[256*sizeof (double)];
stream.Read(buffer, 0, buffer.Length);
double[] newValues = new double[buffer.Length/sizeof (double)];
for (int i = 0; i < newValues.Length; i++)
{
newValues[i] = BitConverter.ToDouble(buffer, i*sizeof (double));
}
stream.Flush();
return newValues;
}
}
接收数据,但由于某些原因不起作用
public partial class MainWindow : Window
{
private Thread _thread;
private double[] _values;
private Server _server = new Server(55443);
public MainWindow()
{
InitializeComponent();
InitializeThread();
}
private void InitializeThread()
{
_thread = new Thread(GetData);
_thread.IsBackground = true;
_thread.Start();
}
private void GetData()
{
while (true)
{
_values = _server.GetData();
Console.WriteLine("...");
}
}
}
好的,客户端发送一个字节数组,这部分工作正常。然后我们需要在单独的线程中将这个字节数组放入无限循环中。就像在这个地方:
private void InitializeThread()
{
_thread = new Thread(GetData);
_thread.IsBackground = true;
_thread.Start();
}
private void GetData()
{
while (true)
{
_values = _server.GetData();
Console.WriteLine("...");
}
}
但是不知何故,服务器只接收到一个字节数组,接下来什么也没有发生。您可以在代码中找到函数 GetData
最佳答案
你把循环放错地方了!
您的客户端仅连接一次;哪个是对的。但是,在您的 GetData
函数中您接受了一个新连接。因此,在第一次读取之后,循环再次调用 GetData
,这会在等待新连接时阻塞,但什么也没有发生。
相反,您想在服务器类本身中循环调用 Accept
,当您获得连接时,为它启动一个“Read”线程(当您获得数据时引发一个事件) .在处理服务器操作的主应用程序中不应有循环。
关于C# TCP 服务器-客户端 : can't receive data from the client in an infinite loop,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/26720229/
如果数据是从另一台计算机(首先)“发送”的,我如何设置我的套接字例程以“发送”(首先)或(切换)“接收”? 谢谢 通用代码: -(void) TcpClient{ char buffer[12
我正在尝试在代码中使用 Java 8 方法引用。有四种类型的方法引用可用。 静态方法引用。 实例方法(绑定(bind)接收者)。 实例方法(未绑定(bind)接收者)。 构造函数引用。 使用静态方法引
我正在尝试在我的代码中使用 Java 8 方法引用。有四种类型的方法引用可用。 静态方法引用。 实例方法(绑定(bind)接收器)。 实例方法(UnBound 接收器)。 构造函数引用。 使用静态方法
这个问题在这里已经有了答案: X does not implement Y (... method has a pointer receiver) (4 个答案) 关闭 3 年前。 最近在研究Iri
我把这个问题/错误发布到 GIT 官方 channel ,但没有得到任何回应。希望这里有人可以帮助我。 当 receive.denyCurrentBranch 设置为 updateInstead 并且
我正在开发一个新的监控系统,该系统可以测量 Celery 队列吞吐量并在队列备份时帮助提醒团队。在我的工作过程中,我遇到了一些我不理解的奇怪行为(并且在 Celery 规范中没有详细记录)。 出于测试
我正在开发一个新的监控系统,该系统可以测量 Celery 队列吞吐量并在队列备份时帮助提醒团队。在我的工作过程中,我遇到了一些我不理解的奇怪行为(并且在 Celery 规范中没有详细记录)。 出于测试
这个问题在这里已经有了答案: What does this Google Play APK publish error message mean? (17 个答案) 关闭 3 年前。 我为我的应用程
我正在寻找一种解决方案来从我的 child “药物”中获取数据,并使用 ID 从“medication_plan”节点接收特定数据并将它们显示在 Recyclerview 中。 数据库结构: 目前我正
我正在构建 DNN 来预测对象是否存在于图像中。我的网络有两个隐藏层,最后一层看起来像这样: # Output layer W_fc2 = weight_variable([2048, 1])
我有一个模拟销售漏斗的 WF4 服务。它的工作原理是从“注册”接听电话开始。之后,有 10 个类似的阶段(每个阶段包含 2 个接收)。在当前阶段验证接收到的数据之前,您不能前进到一个阶段。但我不确定的
我有一个用 NSubstitute 伪造的对象,它有一个被调用两次的方法。我想验证该方法实际上已被调用两次(且仅调用两次)。我浏览了文档和谷歌,但没有运气。任何帮助,将不胜感激。谢谢。 最佳答案 NS
我在 Windows 上使用 D 编写了一个套接字服务器,现在我想将它移植到 Linux 上。这是代码摘要: /* * this.rawsocks - SocketSet * this.serve
我有一个在 AndroidManifest.xml 中定义了 Receiver 的应用程序,它似乎随机地被禁用,这导致应用程序强制关闭,直到重新安装应用程序。在发生这种情况之前,应用可能会在一天、一周
我正在尝试使用 android 注释库通过两种方式进行广播接收器,但 ide 无法识别此代码中的 @Receiver 或 @ReceiverAction import android.content.
我正在试验 Android 的 LiveData .我只是试图将大量通知推送给观察 LiveData 对象的观察者。我让一个线程在后台运行,在一个 while 循环中,我不断地通过 LiveData
当我运行以下代码时: [Test] public async Task Can_Test_Update() { var response = await _controller.UpdateA
查看 header 时,似乎第二台接收邮件的服务器直到最终 header 中报告的送达日期之后才转发它。 在 c9mailgw11.amadis.com,报告的时间是 22:47:49 -0800
我在这里搜索了几个问题都没有得到答案,所以我会根据我的具体情况询问。 真正简单的接收后 Hook ,它只是 curl 到 Redmine 以强制 Redmine 在提交时更新 repo 的 View
我目前正在尝试 Elixir。我对 Ruby 或函数式编程的经验很少,所以我不太熟悉语法。我在读Learn Elixir in Y minutes其中一个例子让我有点困惑。起初,指南显示了 case
我是一名优秀的程序员,十分优秀!