LJProxy/Controllers/L1SvrController.cs

using LJLib.Client;
using LJLib.Net.SPI.Client;
using LJLib.Net.SPI.Com;
using LJProxy.Models;
using LJProxy.Settings;
using Microsoft.AspNetCore.Mvc;
using Microsoft.Extensions.Options;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Threading.Tasks;
using Newtonsoft.Json;
using System.IO;
using System.Text;
using Newtonsoft.Json.Linq;

namespace LJProxy.Controllers
{
    [Route("api/[controller]")]
    [ApiController]
    public class L1SvrController : Controller
    {
        private static object _syncRoot = new object();
        public static AppSettings _appSettingModel;
        public L1SvrController(IOptions<AppSettings> appSettingModel)
        {
            if (_appSettingModel == null)
            {
                _appSettingModel = appSettingModel.Value;
            }
        }
        private static ILJClient _PROPool { get; set; }
        private static ILJClient PROPool
        {
            get
            {
                if (_PROPool == null)
                {
                    lock (_syncRoot)
                    {
                        var url = _appSettingModel.L1SvrPROUrl;
                        var urlArr = url.Split(':');
                        var ip = urlArr[0];
                        var port = urlArr[1];
                        var creator = new DirectP1ClientCreator(ip, Convert.ToInt32(port));
                        _PROPool = new LJClientPool(creator, 1000);
                    }
                }
                return _PROPool;
            }
        }
        private static ILJClient _CRPPool { get; set; }
        private static ILJClient CRPPool
        {
            get
            {
                if (_CRPPool == null)
                {
                    lock (_syncRoot)
                    {
                        var url = _appSettingModel.L1SvrCRPUrl;
                        var urlArr = url.Split(':');
                        var ip = urlArr[0];
                        var port = urlArr[1];
                        var creator = new DirectP1ClientCreator(ip, Convert.ToInt32(port));
                        _CRPPool = new LJClientPool(creator, 20);
                    }
                }
                return _CRPPool;
            }
        }

        [Route("PRO/{apiName}")]
        [HttpPost]
        public string PRO(string apiName, [FromBody] object requestBody)
        {
            var rslt = PROPool.DoExcute(apiName, requestBody.ToString());
            return rslt;
        }

        [Route("CRP/{apiName}/{**restPath}")]
        [HttpPost]
        [HttpGet]
        public async Task<IActionResult> CRP(string apiName)
        { 
            string requestBody;
            using(StreamReader reader = new StreamReader(Request.Body,Encoding.UTF8))
            {
                requestBody = await reader.ReadToEndAsync();
            }
            var excuteResult = GlobalVar.Excute(apiName, requestBody, Request);
            if (excuteResult.Item1) return excuteResult.Item2;
            else
            {
                var rslt = CRPPool.DoExcute(apiName, requestBody);
                return Content(rslt,"application/json");
            }
        }

    }
}