如何在UsePackageHandler获取接收到的消息

[yushangbo]

var client = new EasyClient(new LinePipelineFilter())
.AsClient();
var connected = await client.ConnectAsync(new DnsEndPoint(_serverAddress, _serverPort));
await client.SendAsync(Encoding.UTF8.GetBytes("1111111111" + "\r\n"));
以上代码可以连接成功,发送消息成功，但是server端UsePackageHandler收不到消息如何处理？

[kerryjiang]

服务器端用的什么协议?

[kerryjiang]

Follow this unit test as sample:

SuperSocket/test/SuperSocket.Tests/ClientTest.cs

Lines 35 to 99 in 9bd0141

	[Theory]
	[Trait("Category", "Client.TestEcho")]
	[InlineData(typeof(RegularHostConfigurator), false)]
	[InlineData(typeof(SecureHostConfigurator), false)]
	[InlineData(typeof(GzipHostConfigurator), false)]
	[InlineData(typeof(GzipSecureHostConfigurator), false)]
	[InlineData(typeof(RegularHostConfigurator), true)]
	public async Task TestEcho(Type hostConfiguratorType, bool clientReadAsDemand)
	{
	var serverSessionEvent = new AutoResetEvent(false);
	var hostConfigurator = CreateObject<IHostConfigurator>(hostConfiguratorType);
	using (var server = CreateSocketServerBuilder<TextPackageInfo, LinePipelineFilter>(hostConfigurator)
	.UsePackageHandler(async (s, p) =>
	{
	await s.SendAsync(Utf8Encoding.GetBytes(p.Text + "\r\n"));
	})
	.UseSessionHandler(
	onConnected: (s) =>
	{
	serverSessionEvent.Set();
	return ValueTask.CompletedTask;
	},
	onClosed: (s, e) =>
	{
	serverSessionEvent.Set();
	return ValueTask.CompletedTask;
	})
	.BuildAsServer())
	{
	Assert.Equal("TestServer", server.Name);
	Assert.True(await server.StartAsync());
	OutputHelper.WriteLine("Server started.");
	var options = new ConnectionOptions
	{
	Logger = NullLogger.Instance,
	ReadAsDemand = clientReadAsDemand
	};
	var client = hostConfigurator.ConfigureEasyClient(new LinePipelineFilter(), options);
	var connected = await client.ConnectAsync(new IPEndPoint(IPAddress.Loopback, hostConfigurator.Listener.Port));
	Assert.True(connected);
	Assert.True(serverSessionEvent.WaitOne(1000));
	for (var i = 0; i < 100; i++)
	{
	var msg = Guid.NewGuid().ToString();
	await client.SendAsync(Utf8Encoding.GetBytes(msg + "\r\n"));
	var package = await client.ReceiveAsync();
	Assert.NotNull(package);
	Assert.Equal(msg, package.Text);
	}
	await client.CloseAsync();
	Assert.True(serverSessionEvent.WaitOne(1000));
	await server.StopAsync();
	}
	}