0
点赞
收藏
分享

微信扫一扫

.NET6 supersocket 全双工发送和接收消息


​​supersocket官网​​

设想

  1. 建立一个控制台程序Console1, 启动一个socket server
  2. 再建立一个控制台程序Console2, 同样启动一个socket server
  3. 由于我想实现一个全双工的案例, 于是两边就不分"主次"了, 都不断地监听消息 和 发送消息.
  4. 只要接收到消息, 就输出在控制台; 同时立马发一条消息出去.
  5. 如此则生生不息永无止境也.

实现

就是两个控制台项目, 都是​​.NET6​​环境, 都依赖了当前最新的 superSocket版本, 即如下图所示的

.NET6 supersocket 全双工发送和接收消息_C# socket


.NET6 supersocket 全双工发送和接收消息_C# socket_02


在Visual Studio的​​包管理控制台​​中输入如下命令即可:

​Install-Package SuperSocket -Version 2.0.0-beta.11​​ 如下图.

.NET6 supersocket 全双工发送和接收消息_C# socket_03

代码部分

依赖

.NET6 supersocket 全双工发送和接收消息_C# socket_04

Console1

这里明显用到了supersocket官网示例文档的代码
​​​官方文档​​

不过补充一下, 这个官方文档有点小问题, 不能完全照搬, 有一点点小调整.
对比一下就知道了.

// See https://aka.ms/new-console-template for more information


using Microsoft.Extensions.Hosting;
using SuperSocket;
using SuperSocket.ProtoBase;
using System.Text;

internal class Program
{
private static async Task Main(string[] args)
{
var host = SuperSocketHostBuilder
.Create<StringPackageInfo, CommandLinePipelineFilter>()
.UsePackageHandler(async (session, package) =>
{
var result = 0;

string? v = package.Key.ToString();
Console.WriteLine($"svr1 接收: {v}");

string v1 = $"sv1 发送: {v}";
Console.WriteLine(v1);
await session.SendAsync(Encoding.UTF8.GetBytes(v1));
})

//.ConfigureLogging((hostCtx, loggingBuilder) =>
// {
// loggingBuilder.AddConsole();
// })
.ConfigureSuperSocket(options =>
{
options.Name = "Echo Server";
options.Listeners = new List<ListenOptions>() {
new ListenOptions
{
Ip = "Any",
Port = 40410
}
};
})
.Build();


await host.RunAsync();
}
}

Console2

没有使用supersocket, 是简单地发送和接收

using System.Net;
using System.Net.Sockets;
using System.Text;


namespace ConsoleApp2
{
internal class Program2
{
static void Main(string[] args)
{

byte[] arr = new byte[1024];

//1.创建socket对象
Socket socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);


IPAddress address = IPAddress.Parse("127.0.0.1");
int port = 40410;
socket.Connect(address, port);

while (true) {
string v = Guid.NewGuid().ToString() + "\r\n";

byte[] bytes = Encoding.UTF8.GetBytes(v);

socket.Send(bytes);


Console.WriteLine($"svr2 输出:{v}");

Thread.Sleep(100);


//接收
socket.Receive(arr);
string v2 = Encoding.UTF8.GetString(arr);
Console.WriteLine($"svr2 收到:{v2}");

}

}
}
}

效果

C# socket全双工通信示例


举报

相关推荐

0 条评论