我开发了一个打开套接字的服务器,它每秒接收一个整数。这是我的代码。
private void runServer()
{
TcpListener tcpListener = new TcpListener(IPAddress.Any, 16001);
tcpListener.Start();
updateUI("Buscando clientes");
while (true)
{
TcpClient client = tcpListener.AcceptTcpClient();
Thread tcpHandlerThread = new Thread(new ParameterizedThreadStart(tcpHandler));
tcpHandlerThread.Start(client);
}
}
private void tcpHandler(object client)
{
TcpClient mClient = (TcpClient)client;
NetworkStream stream = mClient.GetStream();
byte[] message = new byte[1024];
stream.Read(message, 0, message.Length);
updateUI("HR: " + Encoding.ASCII.GetString(message) + "\n");
stream.Close();
mClient.Close();
}
我想同时连接 4 个设备发送那个 int 数据,但是使用这个代码,服务器停止接收几秒钟,然后一起接收。你能告诉我我必须做哪些改变才能监听 4 个套接字并每秒获取我的 int 数据吗?
编辑:
那是调用 runServer() 的代码
private void cmdServer_Click(object sender, EventArgs e)
{
if (serverStatus)
{
//El servidor está iniciado, así que paramos el servidor
cmdServer.Text = "Run server";
updateUI("Server Stopped.");
serverStatus = false;
cmbEventos.Enabled = true;
lblTituloEvento.ForeColor = System.Drawing.Color.Orange;
lblTituloEvento.Text = "Selecciona el evento y pulsa Iniciar Servidor";
}
else
{
Thread tcpServerRunThread = new Thread(new ThreadStart(runServer));
tcpServerRunThread.Start();
updateUI("Server is now running.");
cmdServer.Text = "Stop server";
serverStatus = true;
cmbEventos.Enabled = false;
lblTituloEvento.ForeColor = System.Drawing.Color.Green;
lblTituloEvento.Text = "Server " + cmbEventos.Text + " Online";
int numConvert;
bool resultado = int.TryParse(cmbEventos.SelectedValue.ToString(), out numConvert);
idEvento = numConvert;
}
}
编辑 2:
我按照用户所说添加了循环:
private void tcpHandler(object client)
{
TcpClient mClient = (TcpClient)client;
NetworkStream stream = mClient.GetStream();
StringBuilder myCompleteMessage = new StringBuilder();
byte[] message = new byte[1024];
int numberOfBytesRead;
// Incoming message may be larger than the buffer size.
do
{
numberOfBytesRead = stream.Read(message, 0, message.Length);
myCompleteMessage.AppendFormat("{0}", Encoding.ASCII.GetString(message, 0, numberOfBytesRead));
}
while (stream.DataAvailable);
//Old Reading
//stream.Read(message, 0, message.Length);
String messageRec = myCompleteMessage.ToString();
String[] auxMessage = messageRec.Split(new Char[] { '-' });
switch (auxMessage[0])
{
case "HR":
//HR command received
updateUI("HR: " + auxMessage[1] + "\n");
break;
}
stream.Close();
mClient.Close();
}
最佳答案
您没有使用 Read 的返回值。它告诉您实际收到了多少字节,其中最小的是一个。
通常,您需要循环读取。
TCP 提供无边界的字节流。如果你想发送消息,你需要发明某种协议(protocol)来做到这一点。例如,长度为前缀的 protobuf 是一个好主意。
此外,您的设计能够处理多个客户端。它应该有效。
You need async processing.
不,这与问题无关。对套接字使用线程就好了。
关于C# 接收 TCP/IP 多套接字服务器,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/32607713/
我正在尝试使用ruby和Savon来使用网络服务。测试服务为http://www.webservicex.net/WS/WSDetails.aspx?WSID=9&CATID=2require'rubygems'require'savon'client=Savon::Client.new"http://www.webservicex.net/stockquote.asmx?WSDL"client.get_quotedo|soap|soap.body={:symbol=>"AAPL"}end返回SOAP异常。检查soap信封,在我看来soap请求没有正确的命名空间。任何人都可以建议我
我想安装一个带有一些身份验证的私有(private)Rubygem服务器。我希望能够使用公共(public)Ubuntu服务器托管内部gem。我读到了http://docs.rubygems.org/read/chapter/18.但是那个没有身份验证-如我所见。然后我读到了https://github.com/cwninja/geminabox.但是当我使用基本身份验证(他们在他们的Wiki中有)时,它会提示从我的服务器获取源。所以。如何制作带有身份验证的私有(private)Rubygem服务器?这是不可能的吗?谢谢。编辑:Geminabox问题。我尝试“捆绑”以安装新的gem..
最近,当我启动我的Rails服务器时,我收到了一长串警告。虽然它不影响我的应用程序,但我想知道如何解决这些警告。我的估计是imagemagick以某种方式被调用了两次?当我在警告前后检查我的git日志时。我想知道如何解决这个问题。-bcrypt-ruby(3.1.2)-better_errors(1.0.1)+bcrypt(3.1.7)+bcrypt-ruby(3.1.5)-bcrypt(>=3.1.3)+better_errors(1.1.0)bcrypt和imagemagick有关系吗?/Users/rbchris/.rbenv/versions/2.0.0-p247/lib/ru
在Rails4.0.2中,我使用s3_direct_upload和aws-sdkgems直接为s3存储桶上传文件。在开发环境中它工作正常,但在生产环境中它会抛出如下错误,ActionView::Template::Error(noimplicitconversionofnilintoString)在View中,create_cv_url,:id=>"s3_uploader",:key=>"cv_uploads/{unique_id}/${filename}",:key_starts_with=>"cv_uploads/",:callback_param=>"cv[direct_uplo
我有一个存储主机名的Ruby数组server_names。如果我打印出来,它看起来像这样:["hostname.abc.com","hostname2.abc.com","hostname3.abc.com"]相当标准。我想要做的是获取这些服务器的IP(可能将它们存储在另一个变量中)。看起来IPSocket类可以做到这一点,但我不确定如何使用IPSocket类遍历它。如果它只是尝试像这样打印出IP:server_names.eachdo|name|IPSocket::getaddress(name)pnameend它提示我没有提供服务器名称。这是语法问题还是我没有正确使用类?输出:ge
我正在处理旧代码的一部分。beforedoallow_any_instance_of(SportRateManager).toreceive(:create).and_return(true)endRubocop错误如下:Avoidstubbingusing'allow_any_instance_of'我读到了RuboCop::RSpec:AnyInstance我试着像下面那样改变它。由此beforedoallow_any_instance_of(SportRateManager).toreceive(:create).and_return(true)end对此:let(:sport_
如何在ruby中调用C#dll? 最佳答案 我能想到几种可能性:为您的DLL编写(或找人编写)一个COM包装器,如果它还没有,则使用Ruby的WIN32OLE库来调用它;看看RubyCLR,其中一位作者是JohnLam,他继续在Microsoft从事IronRuby方面的工作。(估计不会再维护了,可能不支持.Net2.0以上的版本);正如其他地方已经提到的,看看使用IronRuby,如果这是您的技术选择。有一个主题是here.请注意,最后一篇文章实际上来自JohnLam(看起来像是2009年3月),他似乎很自在地断言RubyCL
我想在Ruby中创建一个用于开发目的的极其简单的Web服务器(不,不想使用现成的解决方案)。代码如下:#!/usr/bin/rubyrequire'socket'server=TCPServer.new('127.0.0.1',8080)whileconnection=server.acceptheaders=[]length=0whileline=connection.getsheaders想法是从命令行运行这个脚本,提供另一个脚本,它将在其标准输入上获取请求,并在其标准输出上返回完整的响应。到目前为止一切顺利,但事实证明这真的很脆弱,因为它在第二个请求上中断并出现错误:/usr/b
您如何在Rails中的实时服务器上进行有效调试,无论是在测试版/生产服务器上?我试过直接在服务器上修改文件,然后重启应用,但是修改好像没有生效,或者需要很长时间(缓存?)我也试过在本地做“脚本/服务器生产”,但是那很慢另一种选择是编码和部署,但效率很低。有人对他们如何有效地做到这一点有任何见解吗? 最佳答案 我会回答你的问题,即使我不同意这种热修补服务器代码的方式:)首先,你真的确定你已经重启了服务器吗?您可以通过跟踪日志文件来检查它。您更改的代码显示的View可能会被缓存。缓存页面位于tmp/cache文件夹下。您可以尝试手动删除
我正在尝试在Ruby中复制Convert.ToBase64String()行为。这是我的C#代码:varsha1=newSHA1CryptoServiceProvider();varpasswordBytes=Encoding.UTF8.GetBytes("password");varpasswordHash=sha1.ComputeHash(passwordBytes);returnConvert.ToBase64String(passwordHash);//returns"W6ph5Mm5Pz8GgiULbPgzG37mj9g="当我在Ruby中尝试同样的事情时,我得到了相同sha