using System;
|
using System.Collections.Generic;
|
using System.Configuration;
|
using System.Linq;
|
|
namespace Sodao.FastSocket.Server
|
{
|
/// <summary>
|
/// Socket server manager.
|
/// </summary>
|
public class SocketServerManager
|
{
|
#region Private Members
|
/// <summary>
|
/// key:server name.
|
/// </summary>
|
static private readonly Dictionary<string, SocketBase.IHost> _dicHosts = new Dictionary<string, SocketBase.IHost>();
|
#endregion
|
|
#region Static Methods
|
/// <summary>
|
/// 初始化Socket Server
|
/// </summary>
|
static public void Init()
|
{
|
Init("socketServer");
|
}
|
|
/// <summary>
|
/// 初始化Socket Server
|
/// </summary>
|
/// <param name="sectionName"></param>
|
static public void Init(string sectionName)
|
{
|
if (string.IsNullOrEmpty(sectionName)) throw new ArgumentNullException("sectionName");
|
Init(ConfigurationManager.GetSection(sectionName) as Config.SocketServerConfig);
|
}
|
|
/// <summary>
|
/// 初始化Socket Server
|
/// </summary>
|
/// <param name="config"></param>
|
static public void Init(Config.SocketServerConfig config)
|
{
|
if (config == null) throw new ArgumentNullException("config");
|
if (config.Servers == null) return;
|
|
foreach (Config.Server serverConfig in config.Servers)
|
{
|
|
//init protocol
|
var objProtocol = GetProtocol(serverConfig.Protocol);
|
if (objProtocol == null) throw new InvalidOperationException("protocol");
|
|
//init custom service
|
var tService = Type.GetType(serverConfig.ServiceType, false);
|
if (tService == null) throw new InvalidOperationException("serviceType");
|
|
var objService = Activator.CreateInstance(tService);
|
if (objService == null) throw new InvalidOperationException("serviceType");
|
|
//init host.
|
_dicHosts.Add(serverConfig.Name, Activator.CreateInstance(
|
typeof(SocketServer<>).MakeGenericType(
|
objProtocol.GetType().GetInterface(typeof(Protocol.IProtocol<>).Name).GetGenericArguments()),
|
serverConfig.Port,
|
objService,
|
objProtocol,
|
serverConfig.SocketBufferSize,
|
serverConfig.MessageBufferSize,
|
serverConfig.MaxMessageSize,
|
serverConfig.MaxConnections) as SocketBase.IHost);
|
|
}
|
|
}
|
|
/// <summary>
|
/// 初始化Socket Server
|
/// </summary>
|
/// <param name="nSocketPort">端口号</param>
|
static public void Init(int nSocketPort)
|
{
|
Init("socketServer", nSocketPort);
|
}
|
/// <summary>
|
/// 初始化Socket Server
|
/// </summary>
|
/// <param name="sectionName"></param>
|
static public void Init(string sectionName, int nSocketPort)
|
{
|
if (string.IsNullOrEmpty(sectionName)) throw new ArgumentNullException("sectionName");
|
Init(ConfigurationManager.GetSection(sectionName) as Config.SocketServerConfig, nSocketPort);
|
}
|
|
#region 定制方便修改端口号
|
|
/// <summary>
|
/// 初始化Socket Server
|
/// </summary>
|
/// <param name="config"></param>
|
static public void Init(Config.SocketServerConfig config, int nSocketPort)
|
{
|
if (config == null) throw new ArgumentNullException("config");
|
if (config.Servers == null) return;
|
|
foreach (Config.Server serverConfig in config.Servers)
|
{
|
//init protocol
|
var objProtocol = GetProtocol(serverConfig.Protocol);
|
|
if (objProtocol == null) throw new InvalidOperationException("protocol");
|
|
//init custom service
|
var tService = Type.GetType(serverConfig.ServiceType, false);
|
if (tService == null) throw new InvalidOperationException("serviceType");
|
|
var objService = Activator.CreateInstance(tService);
|
if (objService == null) throw new InvalidOperationException("serviceType");
|
if (nSocketPort == 0) nSocketPort = serverConfig.Port;
|
|
//init host.
|
_dicHosts.Add(serverConfig.Name, Activator.CreateInstance(
|
typeof(SocketServer<>).MakeGenericType(
|
objProtocol.GetType().GetInterface(typeof(Protocol.IProtocol<>).Name).GetGenericArguments()),
|
nSocketPort,
|
objService,
|
objProtocol,
|
serverConfig.SocketBufferSize,
|
serverConfig.MessageBufferSize,
|
serverConfig.MaxMessageSize,
|
serverConfig.MaxConnections) as SocketBase.IHost);
|
|
}
|
}
|
#endregion
|
|
/// <summary>
|
/// get protocol.
|
/// </summary>
|
/// <param name="protocol"></param>
|
/// <returns></returns>
|
static public object GetProtocol(string protocol)
|
{
|
switch (protocol)
|
{
|
case Protocol.ProtocolNames.Thrift: return new Protocol.ThriftProtocol();
|
case Protocol.ProtocolNames.CommandLine: return new Protocol.CommandLineProtocol();
|
case Protocol.ProtocolNames.HxProtocol: return new Protocol.HxProtocol();
|
}
|
return Activator.CreateInstance(Type.GetType(protocol, false));
|
}
|
|
/// <summary>
|
/// 启动服务
|
/// </summary>
|
static public void Start()
|
{
|
_dicHosts.ToList().ForEach(c => c.Value.Start());
|
}
|
/// <summary>
|
/// 停止服务
|
/// </summary>
|
static public void Stop()
|
{
|
_dicHosts.ToList().ForEach(c => c.Value.Stop());
|
}
|
/// <summary>
|
/// try get host by name.
|
/// </summary>
|
/// <param name="name"></param>
|
/// <param name="host"></param>
|
/// <returns></returns>
|
static public bool TryGetHost(string name, out SocketBase.IHost host)
|
{
|
return _dicHosts.TryGetValue(name, out host);
|
}
|
#endregion
|
}
|
}
|
