.netcore 使用surging框架发布到docker

},
{
"Name": "maxSize",
"Value": "10"
}
] }
]}

新增eventBusSettings.json，其中的EventBusConnection对应的是RabbitMQ docker的地址

{
 "EventBusConnection": "172.17.0.3",
 "EventBusUserName": "guest",
 "EventBusPassword": "guest"
} 

Program.cs的代码如下

using Autofac;
using Surging.Core.Codec.MessagePack;
using Surging.Core.Consul;
using Surging.Core.Consul.Configurations;
using Surging.Core.CPlatform;
using Surging.Core.CPlatform.Utilities;
using Surging.Core.DotNetty;
using Surging.Core.EventBusRabbitMQ;
using Surging.Core.Log4net;
using Surging.Core.ProxyGenerator;
using Surging.Core.ServiceHosting;
using Surging.Core.ServiceHosting.Internal.Implementation;
using System;
using System.Text;
namespace Service.A
{
 class Program
 {
  static void Main(string[] args)
  {
   NewMethod();
  }
  private static void NewMethod()
  {
   Encoding.RegisterProvider(CodePagesEncodingProvider.Instance);
   var host = new ServiceHostBuilder()
    .RegisterServices(builder =>
    {
     builder.AddMicroService(option =>
     {
      option.AddServiceRuntime();
      option.AddRelateService();
      //option.UseZooKeeperManager(new ConfigInfo("127.0.0.1:2181"));
      option.UseConsulManager(new ConfigInfo("172.17.0.4:8500"));
      option.UseDotNettyTransport();
      option.UseRabbitMQTransport();
      option.AddRabbitMQAdapt();
      //option.UseProtoBufferCodec();
      option.UseMessagePackCodec();
      builder.Register(p => new CPlatformContainer(ServiceLocator.Current));
     });
    })
    .SubscribeAt()
    .UseLog4net("Configs/log4net.config")
    //.UseServer("127.0.0.1", 98)
    //.UseServer("127.0.0.1", 98，“true”) //自动生成Token
    //.UseServer("127.0.0.1", 98，“123456789”) //固定密码Token
    .UseServer(options =>
    {
     options.Ip = "172.17.0.6";
     options.Port = 9990;
     options.Token = "True";
     options.ExecutionTimeoutInMilliseconds = 30000;
     options.MaxConcurrentRequests = 200;
     options.NotRelatedAssemblyFiles = "Centa.Agency.Application.DTOw*|StackExchange.Redisw*";
    })
    .UseProxy()
    .UseStartup<Startup>()
    .Build();
   using (host.Run())
   {
    Console.WriteLine($"服务端启动成功，{DateTime.Now}。");
   }
  }
 }
}

新增Startup.cs

using Autofac;
using Autofac.Extensions.DependencyInjection;
using Microsoft.Extensions.Configuration;
using Microsoft.Extensions.DependencyInjection;								 
 3/5   首页 上一页 1 2 3 4 5 下一页 尾页