多服务器实例问题

[trackycn]

1. 使用 AddServer 方法添加多个服务器时, 如果使用 AddServer<TReceivePackage, TPipelineFilter> 这样的重载, 将只有第一个服务可以监听, 之后的服务都未监听; 如果改为 AddServer<TSuperSocketService, TReceivePackage, TPipelineFilter>, 则一切正常;
2. 在 AddServer 里为每个服务都调用了 UseInProcSessionContainer(), 但是获取 ISessionContainer 仍然为空;

示例代码:

var hostBuilder = MultipleServerHostBuilder.Create()
    .ConfigureAppConfiguration((hostCtx, configApp) =>
    {
        configApp.AddJsonFile("appsettings.json", true);
    })
    .AddServer<TextPackageInfo, LinePipelineFilter>(builder =>
    {
        builder
            .ConfigureServerOptions((ctx, config) => config.GetSection("TestServer1"))
            .UsePackageHandler(async (s, p) =>
            {
                Console.WriteLine($"TestServer1: {p.Text}");
            })
            .UseInProcSessionContainer();
    })
    .AddServer<TextPackageInfo, LinePipelineFilter>(builder =>
    {
        builder
            .ConfigureServerOptions((ctx, config) => config.GetSection("TestServer2"))
            .UsePackageHandler(async (s, p) =>
            {
                Console.WriteLine($"TestServer2: {p.Text}");
            })
            .UseInProcSessionContainer();
    })
    .ConfigureLogging((hostCtx, loggingBuilder) =>
    {
        loggingBuilder.AddConsole();
        loggingBuilder.AddDebug();
    });



var host = hostBuilder.Build();
await host.StartAsync();

var session = host.Services.GetService<ISessionContainer>();

Console.ReadLine();

appsettings.json 配置:

{
  "serverOptions": {
    "TestServer1": {
      "name": "TestServer1",
      "listeners": [
        {
          "ip": "Any",
          "port": 4040
        }
      ]
    },
    "TestServer2": {
      "name": "TestServer2",
      "listeners": [
        {
          "ip": "Any",
          "port": 4041
        }
      ]
    }
  }
}

[jcreator35]

https://docs.supersocket.net/v2-0/zh-CN/Multiple-Server-Instances 文档里讲的很清楚了，你要运行多个SuperSocket服务器实例就必须得用AddServer<TSuperSocketService, TReceivePackage, TPipelineFilter>

[trackycn]

https://docs.supersocket.net/v2-0/zh-CN/Multiple-Server-Instances 文档里讲的很清楚了，你要运行多个SuperSocket服务器实例就必须得用AddServer<TSuperSocketService, TReceivePackage, TPipelineFilter>

test 项目里的示例都是用没有 TSuperSocketService 的重载的; 还有第二个 ISessionContainer 为空的也要麻烦作者看下

SuperSocket/test/SuperSocket.Tests/AspNetIntegrationTest.cs

Lines 112 to 152 in 9bd0141

	public async Task TestMultipleHostServiceAccess()
	{
	var builder = Host.CreateDefaultBuilder()
	.ConfigureWebHostDefaults(webBuilder =>
	{
	webBuilder.UseStartup<Startup>();
	webBuilder.ConfigureKestrel(config =>
	{
	config.Listen(IPAddress.Any, _defaultPort);
	});
	})
	.AsMultipleServerHostBuilder()
	.ConfigureAppConfiguration((hostingContext, config) =>
	{
	config.Sources.Clear();
	config.AddJsonFile("Config/multiple_server.json", optional: false, reloadOnChange: true);
	})
	.AddServer<TextPackageInfo, LinePipelineFilter>(builder =>
	{
	builder
	.ConfigureServerOptions((ctx, config) =>
	{
	return config.GetSection("TestServer1");
	});
	});
	using (var host = builder.Build())
	{
	await host.StartAsync();
	var server = host.AsServer();
	Assert.IsType<TestService>(server.ServiceProvider.GetService<ITestService>());
	using (var scope = server.ServiceProvider.CreateScope())
	{
	Assert.IsType<ScopedTestService>(scope.ServiceProvider.GetService<IScopedTestService>());
	}
	await host.StopAsync();
	}
	}

[jcreator35]

            var hostBuilder = MultipleServerHostBuilder.Create()
                .AddServer<TextPackageInfo, LinePipelineFilter>(builder =>
                {
                    builder
                    .UsePackageHandler(async (session, package) =>
                    {                         
                        Console.WriteLine($"TestServer1: {package.Text}");
                    })  
                    .ConfigureServerOptions((ctx, config) =>
                    {
                        return config.GetSection("TestServer1");
                    });
                })
                .AddServer<StringPackageInfo, TerminatorPipelineFilter<StringPackageInfo>>(builder =>
                {
                    builder
                    .UsePackageHandler(async (session, package) =>
                    {
                        Console.WriteLine($"TestServer2: {package.ToString()}");
                    })
                    .ConfigureServerOptions((ctx, config) =>
                    {
                        return config.GetSection("TestServer2");
                    });
                })
                .Build();

            await hostBuilder.RunAsync();

这样也可以正常启动多个实例，但是你的服务器实例不能相同，比如第一个是 .AddServer<TextPackageInfo, LinePipelineFilter>，那么第二个就必须是其他的类型，例如代码中的 .AddServer<StringPackageInfo, TerminatorPipelineFilter<StringPackageInfo>>

关于ISessionContainer为null的问题，因为使用的是MultipleServerHostBuilder，所以应该是
var session = hostBuilder.Services.GetServices<ISessionContainer>();
而不是
var session = hostBuilder.Services.GetService<ISessionContainer>();
你用错了方法，请仔细看两个方法的区别,一个是GetServices，一个是GetService

[trackycn]

            var hostBuilder = MultipleServerHostBuilder.Create()
                .AddServer<TextPackageInfo, LinePipelineFilter>(builder =>
                {
                    builder
                    .UsePackageHandler(async (session, package) =>
                    {                         
                        Console.WriteLine($"TestServer1: {package.Text}");
                    })  
                    .ConfigureServerOptions((ctx, config) =>
                    {
                        return config.GetSection("TestServer1");
                    });
                })
                .AddServer<StringPackageInfo, TerminatorPipelineFilter<StringPackageInfo>>(builder =>
                {
                    builder
                    .UsePackageHandler(async (session, package) =>
                    {
                        Console.WriteLine($"TestServer2: {package.ToString()}");
                    })
                    .ConfigureServerOptions((ctx, config) =>
                    {
                        return config.GetSection("TestServer2");
                    });
                })
                .Build();

            await hostBuilder.RunAsync();

**这样也可以正常启动多个实例，但是你的服务器实例不能相同，比如第一个是**` .AddServer`，**那么第二个就必须是其他的类型，例如代码中的**` .AddServer>`

关于ISessionContainer为null的问题，因为使用的是MultipleServerHostBuilder，所以应该是 var session = hostBuilder.Services.GetServices<ISessionContainer>(); 而不是 var session = hostBuilder.Services.GetService<ISessionContainer>(); 你用错了方法，请仔细看两个方法的区别,一个是GetServices，一个是GetService

无论 GetServices 和 GetService 都不行, ServiceDescriptors 没有 ISessionContainer

[kerryjiang]

Something to be optimized in SuperSocket about this problem.

[x0gundam1133]

Something to be optimized in SuperSocket about this problem.

请问可以webserver + appserver 多实例运行么？

[kerryjiang]

Updated the unit TestMultipleServerHost to cover your case.

SuperSocket/test/SuperSocket.Tests/MainTest.cs

Line 670 in 5dc9519

public async Task TestMultipleServerHost()

[kerryjiang]

@trackycn ISessionContainer 不是在host的ServiceProvider里面，是在server的ServiceProvider里面。看我上面发的链接里面的测试用例。

[trackycn]

@trackycn ISessionContainer 不是在host的ServiceProvider里面，是在server的ServiceProvider里面。看我上面发的链接里面的测试用例。

thx, 我看下! 辛苦了!