我一直在用 C# 编写一个文件服务器/客户端应用程序，它似乎可以正常工作，但后来我意识到流没有被推进，客户端一直无法从服务器接收。所以我检查了 wireshark，发现我的客户端正在发出 TCPZeroWindow 标记的数据包。有什么想法吗？谢谢。
客户:
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using System.Net;
using System.Net.Sockets;
using System.IO;
namespace PortalClient
{
class Program
{
static string s1;
static byte[] data03;
static int int02;
static string str01;
static int length;
static IPEndPoint ipe01;
static TcpClient tcp01;
static FileStream s01;
static string ip01;
static string port01;
static string path01;
static byte[] data01;
static byte[] data02;
static byte[] data04;
static void Main(string[] args)
{
while (true)
{
label1:
{
try
{
string version = "V:1.1.4";
Console.Title = (" Portal Client " + version);
ConsoleColor ccolor1 = new ConsoleColor();
ccolor1 = Console.ForegroundColor;
Console.ForegroundColor = ConsoleColor.Green;
Console.WriteLine();
Console.WriteLine(" PORTAL CLIENT " + version);
Console.WriteLine();
Console.ForegroundColor = ccolor1;
data01 = new byte[20];
data03 = new byte[100];
data04 = new byte[100];
Console.Write(" Enter IPv4 address of server : ");
ip01 = Console.ReadLine();
Console.Write(" Enter port to connect on : ");
port01 = Console.ReadLine();
ipe01 = new IPEndPoint(IPAddress.Parse(ip01), Convert.ToInt32(port01));
tcp01 = new TcpClient();
tcp01.ReceiveTimeout = 2500;
tcp01.NoDelay = true;
Console.WriteLine(" Connecting...");
tcp01.Connect(ipe01);
Console.WriteLine(" Done.");
tcp01.Client.Receive(data04, SocketFlags.None);
System.Threading.Thread.Sleep(100);
Console.WriteLine(" Server message : " + Encoding.UTF8.GetString(data04));
tcp01.Client.Receive(data03, SocketFlags.None);
System.Threading.Thread.Sleep(100);
Console.WriteLine(" File on server : " + Encoding.UTF8.GetString(data03));
tcp01.Client.Receive(data01, SocketFlags.None);
System.Threading.Thread.Sleep(100);
str01 = Encoding.UTF8.GetString(data01);
Console.WriteLine();
Console.WriteLine(" file size : " + str01);
Console.WriteLine();
Console.Write(" Enter the number you see above : ");
length = Convert.ToInt32(Console.ReadLine());
Console.Write(" Save file as : ");
path01 = Console.ReadLine();
for (int i = 1; i <= 9000; i++)
{
if (length % i == 0) { int02 = i; }
}
if (length < 9000) { int02 = length; }
int int03 = length / int02;
s01 = File.OpenWrite(@path01);
Console.WriteLine(" Receiving file from " + tcp01.Client.RemoteEndPoint.ToString() + "...");
tcp01.Client.Send(new byte[1], SocketFlags.None);
System.Threading.Thread.Sleep(1000);
for (int i = 0; i <= int03; i++)
{
bool bool1 = false;
data02 = new byte[int02];
int n = tcp01.Client.Receive(data02, 0, int02, SocketFlags.None);
while (n < int02)
{
Console.WriteLine(" Entered Loop ");
int int04 = int02 - n;
tcp01.Client.Send(Encoding.UTF8.GetBytes("2"), 0, 1, SocketFlags.None);
int int05 = 0;
byte[] data05 = new byte[int04];
if (int04 >= 1 && int04 <= 9) { s1 = int04 + "xxx"; }
if (int04 >= 10 && int04 <= 99) { s1 = int04 + "xx"; }
if (int04 >= 100 && int04 <= 999) { s1 = int04 + "x"; }
if (int04 >= 1000 && int04 <= 9000) { s1 = int04.ToString(); }
tcp01.Client.Send(Encoding.UTF8.GetBytes(s1), 0, 4, SocketFlags.None);
int05 = tcp01.Client.Receive(data05, 0, int04, SocketFlags.None);
n = n + int05;
s01.Write(data05, 0, int05);
bool1 = true;
}
if (bool1 == false)
{
s01.Write(data02, 0, int02);
tcp01.Client.Send(new byte[1], 0, 1, SocketFlags.None);
}
}
System.Threading.Thread.Sleep(1000);
s01.Close();
Console.WriteLine(" Received all data.");
Console.WriteLine(" Press enter to disconnect...");
Console.ReadLine();
tcp01.Client.Send(new byte[1], SocketFlags.None);
System.Threading.Thread.Sleep(1000);
Console.WriteLine(" Disconnecting...");
tcp01.Close();
Console.WriteLine(" Done.");
}
catch (Exception e)
{
Console.WriteLine(" Error! : " + e.Message.ToString() + " - " + e.Data.ToString() + " - " + e.TargetSite.ToString()); if (!(tcp01 == null)) { tcp01.Close(); } if (!(s01 == null)) { s01.Close(); goto label1; }
}
}
}
}
}
}
服务器:
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using System.Net;
using System.Net.Sockets;
using System.IO;
namespace PortalServer
{
class Program
{
static long length;
static int int03;
static int int02;
static TcpListener tcp01;
static TcpClient tcp02;
static FileStream s01;
static byte[] data01;
static byte[] data03;
static byte[] data04;
static byte[] data05;
static string str01;
static string str02;
static IPEndPoint ipe01;
static string port01;
static void Main(string[] args)
{
while (true)
{
label1:
try
{
string version = "V:1.1.4";
Console.Title = (" Portal Server " + version);
ConsoleColor ccolor1 = new ConsoleColor();
ccolor1 = Console.ForegroundColor;
Console.ForegroundColor = ConsoleColor.Green;
Console.WriteLine();
Console.WriteLine(" PORTAL SERVER " + version);
Console.WriteLine();
Console.ForegroundColor = ccolor1;
Console.Write(" Enter port for connecting clients : ");
port01 = Console.ReadLine();
Console.Write(" Enter path of file to send : ");
str01 = Console.ReadLine();
ipe01 = new IPEndPoint(IPAddress.Any, Convert.ToInt32(port01));
tcp01 = new TcpListener(ipe01);
Console.Write(" Enter server message : ");
str02 = Console.ReadLine();
s01 = File.OpenRead(@str01);
length = s01.Length;
for (int i = 1; i <= 9000; i++)
{
if (length % i == 0) { int02 = i; }
}
if (length < 9000) { int02 = (int)length;}
int03 = (int)length / int02;
tcp01.Start();
Console.WriteLine(" Server started. Waiting for clients...");
tcp02 = tcp01.AcceptTcpClient();
tcp02.Client.NoDelay = true;
Console.WriteLine(" Client " + tcp02.Client.RemoteEndPoint.ToString() + " connected.");
data05 = Encoding.UTF8.GetBytes(str02);
tcp02.Client.Send(data05, SocketFlags.None);
System.Threading.Thread.Sleep(500);
data04 = Encoding.UTF8.GetBytes(str01);
tcp02.Client.Send(data04, SocketFlags.None);
System.Threading.Thread.Sleep(500);
data03 = Encoding.UTF8.GetBytes(length.ToString());
tcp02.Client.Send(data03, SocketFlags.None);
System.Threading.Thread.Sleep(500);
Console.WriteLine(" Waiting for response...");
tcp02.Client.Receive(new byte[1], SocketFlags.None);
Console.WriteLine(" Received response...");
Console.WriteLine(" Sending file to " + tcp02.Client.RemoteEndPoint.ToString() + "...");
System.Threading.Thread.Sleep(1);
for (int i = 0; i <= int03;i++ )
{
System.Threading.Thread.Sleep(30);
data01 = new byte[int02];
s01.Read(data01, 0, data01.Length);
int n = tcp02.Client.Send(data01, 0 ,data01.Length, SocketFlags.None);
if (n != int02) { throw new Exception("unable to write bytes, insufficient memory."); }
byte[] data07 = new byte[1];
while (true)
{
tcp02.Client.Receive(data07,0,1,SocketFlags.None);
if (Encoding.UTF8.GetString(data07) == "2")
{
byte[] data06 = new byte[4];
int b = tcp02.Client.Receive(data06, 0, 4, SocketFlags.None);
if (b != 4) { throw new Exception("ex1"); }
string s1 = Encoding.UTF8.GetString(data06);
s1 = s1.Replace("x", "");
int int05 = Convert.ToInt32(s1);
int int06 = int02 - int05;
byte[] data08 = new byte[int05];
Buffer.BlockCopy(data01, int06, data08, 0, int05);
tcp02.Client.Send(data08, 0, data08.Length, SocketFlags.None);
System.Threading.Thread.Sleep(30);
}
break;
}
}
System.Threading.Thread.Sleep(1000);
s01.Close();
Console.WriteLine(" All data sent.");
Console.WriteLine(" Waiting for terminate message...");
tcp02.Client.Receive(new byte[1], SocketFlags.None);
Console.WriteLine(" Received terminate message.");
tcp02.Close();
Console.WriteLine(" Stopping client and server.");
tcp01.Stop();
Console.WriteLine(" Done. Restarting.");
}
catch (Exception e)
{
Console.WriteLine(" Error! : " + e.Message.ToString() + " - " + e.Data.ToString() + " - " + e.TargetSite.ToString());
if (!(tcp02 == null)) { tcp02.Close(); }
if (!(tcp01 == null)) { tcp01.Stop(); goto label1; }
}
}
}
}
}
最佳答案
如果您没有在客户端正确清空网络缓冲区，并且 TCP 窗口大小因此减小为零，我已经看到会发生这种情况。
这可能发生在您使用
tcp01.Client.Receive(data04, SocketFlags.None);
可能没有充分清除缓冲区，请参阅 MSDN .您希望连续调用 Receive 直到没有更多数据可用。
如果您想要一个工作示例作为比较，请参阅 here .
关于c# - TCP ZeroWindow 问题 C#，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/14792061/
我想为Heroku构建一个Rails3应用程序。他们使用Postgres作为他们的数据库，所以我通过MacPorts安装了postgres9.0。现在我需要一个postgresgem并且共识是出于性能原因你想要pggem。但是我对我得到的错误感到非常困惑当我尝试在rvm下通过geminstall安装pg时。我已经非常明确地指定了所有postgres目录的位置可以找到但仍然无法完成安装:$envARCHFLAGS='-archx86_64'geminstallpg--\--with-pg-config=/opt/local/var/db/postgresql90/defaultdb/po
尝试通过RVM将RubyGems升级到版本1.8.10并出现此错误:$rvmrubygemslatestRemovingoldRubygemsfiles...Installingrubygems-1.8.10forruby-1.9.2-p180...ERROR:Errorrunning'GEM_PATH="/Users/foo/.rvm/gems/ruby-1.9.2-p180:/Users/foo/.rvm/gems/ruby-1.9.2-p180@global:/Users/foo/.rvm/gems/ruby-1.9.2-p180:/Users/foo/.rvm/gems/rub
我的最终目标是安装当前版本的RubyonRails。我在OSXMountainLion上运行。到目前为止，这是我的过程:已安装的RVM$\curl-Lhttps://get.rvm.io|bash-sstable检查已知(我假设已批准)安装$rvmlistknown我看到当前的稳定版本可用[ruby-]2.0.0[-p247]输入命令安装$rvminstall2.0.0-p247注意:我也试过这些安装命令$rvminstallruby-2.0.0-p247$rvminstallruby=2.0.0-p247我很快就无处可去了。结果:$rvminstall2.0.0-p247Search
由于fast-stemmer的问题，我很难安装我想要的任何rubygem。我把我得到的错误放在下面。Buildingnativeextensions.Thiscouldtakeawhile...ERROR:Errorinstallingfast-stemmer:ERROR:Failedtobuildgemnativeextension./System/Library/Frameworks/Ruby.framework/Versions/2.0/usr/bin/rubyextconf.rbcreatingMakefilemake"DESTDIR="cleanmake"DESTDIR=
当我尝试安装Ruby时遇到此错误。我试过查看this和this但无济于事➜~brewinstallrubyWarning:YouareusingOSX10.12.Wedonotprovidesupportforthispre-releaseversion.Youmayencounterbuildfailuresorotherbreakages.Pleasecreatepull-requestsinsteadoffilingissues.==>Installingdependenciesforruby:readline,libyaml,makedepend==>Installingrub
如何在ruby中调用C#dll？ 最佳答案 我能想到几种可能性:为您的DLL编写(或找人编写)一个COM包装器，如果它还没有，则使用Ruby的WIN32OLE库来调用它；看看RubyCLR,其中一位作者是JohnLam，他继续在Microsoft从事IronRuby方面的工作。(估计不会再维护了，可能不支持.Net2.0以上的版本)；正如其他地方已经提到的，看看使用IronRuby，如果这是您的技术选择。有一个主题是here.请注意，最后一篇文章实际上来自JohnLam(看起来像是2009年3月)，他似乎很自在地断言RubyCL
我正在尝试在Ruby中复制Convert.ToBase64String()行为。这是我的C#代码:varsha1=newSHA1CryptoServiceProvider();varpasswordBytes=Encoding.UTF8.GetBytes("password");varpasswordHash=sha1.ComputeHash(passwordBytes);returnConvert.ToBase64String(passwordHash);//returns"W6ph5Mm5Pz8GgiULbPgzG37mj9g="当我在Ruby中尝试同样的事情时，我得到了相同sha
我正在尝试使用boilerpipe来自JRuby。我看过guide从JRuby调用Java，并成功地将它与另一个Java包一起使用，但无法弄清楚为什么同样的东西不能用于boilerpipe。我正在尝试基本上从JRuby中执行与此Java等效的操作:URLurl=newURL("http://www.example.com/some-location/index.html");Stringtext=ArticleExtractor.INSTANCE.getText(url);在JRuby中试过这个:require'java'url=java.net.URL.new("http://www
我意识到这可能是一个非常基本的问题，但我现在已经花了几天时间回过头来解决这个问题，但出于某种原因，Google就是没有帮助我。(我认为部分问题在于我是一个初学者，我不知道该问什么......)我也看过O'Reilly的RubyCookbook和RailsAPI，但我仍然停留在这个问题上.我找到了一些关于多态关系的信息，但它似乎不是我需要的(尽管如果我错了请告诉我)。我正在尝试调整MichaelHartl'stutorial创建一个包含用户、文章和评论的博客应用程序(不使用脚手架)。我希望评论既属于用户又属于文章。我的主要问题是:我不知道如何将当前文章的ID放入评论Controller。
首先回顾一下拉格朗日定理的内容：函数f(x)是在闭区间[a,b]上连续、开区间(a,b)上可导的函数，那么至少存在一个，使得:通过这个表达式我们可以知道，f(x)是函数的主体，a和b可以看作是主体函数f(x)中所取的两个值。那么可以有， 也就意味着我们可以用来替换 这种替换可以用在求某些多项式差的极限中。方法： 外层函数f(x)是一致的，并且h(x)和g(x)是等价无穷小。此时，利用拉格朗日定理，将原式替换为 ，再进行求解，往往会省去复合函数求极限的很多麻烦。使用要注意：1.要先找到主体函数f(x)，即外层函数必须相同。2.f(x)找到后，复合部分是等价无穷小。3.要满足作差的形式。如果是加