我的部落格 – 一只河豚

AspNet Core IIS部署 HTTP 错误 500.19 – Internal Server Error

环境：

Windows Server 2016 DC

IIS 10

netcore 2.2

错误产生过程(推测可能性)：

1，项目文件夹从别的地方复制而来

2，NetCore Hosting 重新安装过

3，netcore项目的IIS程序池重建过

4，以上混合

导致的结果：IIS丢失对项目web.config的读取权限

解决办法：为web.config添加【IIS AppPool\netcore程序池名称】账户可读取权限。账户【IIS AppPool\netcore程序池名称】是新建iis池时自动创建的，不能像windows系统账号一样搜索得到。

参考地址：HTTP Error 500.19 – Internal Server Error when publishing ASP.Net Core Web API to IIS Server

其他可能的情况解决办法参考：关于 IIS 上运行 ASP.NET Core 站点的“HTTP 错误 500.19”错误

携程Apollo安装笔记

Apllo：GitHub上官网地址

安装过程参考：Asp.Net Core与携程阿波罗(Apollo)的第一次亲密接触

过程：

0，下载并安装Git Bash，保持最新版：Apllo要求使用Git Bash。

1，下载并安装Java 1.8+ (jdk)。就是Java官网的：Java SE Development Kit

2，下载并安装Mysql 5.6.5+

3，下载Apollo项目

4，修改Apllo项目下demo.sh，修改连接mysql的账号密码(两处，一个是db一个是config)

#!/bin/bash

# apollo config db info
apollo_config_db_url=jdbc:mysql://localhost:3306/ApolloConfigDB?characterEncoding=utf8
apollo_config_db_username=root  #你的mysql给apollo分派的账号
apollo_config_db_password=Apollo123_  #你的mysql给apollo分派的账号密码

# apollo portal db info
apollo_portal_db_url=jdbc:mysql://localhost:3306/ApolloPortalDB?characterEncoding=utf8
apollo_portal_db_username=root #你的mysql给apollo分派的账号
apollo_portal_db_password=Apollo123_ #你的mysql给apollo分派的账号密码

#!/bin/bash

# apollo config db info

apollo_config_db_url=jdbc:mysql://localhost:3306/ApolloConfigDB?characterEncoding=utf8

apollo_config_db_username=root #你的mysql给apollo分派的账号

apollo_config_db_password=Apollo123_ #你的mysql给apollo分派的账号密码

# apollo portal db info

apollo_portal_db_url=jdbc:mysql://localhost:3306/ApolloPortalDB?characterEncoding=utf8

apollo_portal_db_username=root #你的mysql给apollo分派的账号

apollo_portal_db_password=Apollo123_ #你的mysql给apollo分派的账号密码

5，git bash切换到Apllo项目目录下，执行：./demo.sh start

6，等待出现以下讯息表示安装成功

....
Waiting for portal startup.......
Portal started. You can visit http://localhost:8070 now!

....

Waiting for portal startup.......

Portal started. You can visit http://localhost:8070 now!

采坑记录：

1，之前装过mysql，但是root密码忘记了，参考此链接重置ok。百度的结果真是千篇一律每一个能用的。

a)，重置root密码坑：mysql有密码策略，不能太简单，否则重置后无效。密码尽量包含大小写和符号。

b)，注意密码不要有&符号，否则Apollo的 demo.sh start 会异常。

2，mysql默认max_connections是20， demo.sh start 时总是会报 Config service failed to start in 120 seconds! Please check ./service/apollo-service.log for more information.，查看日志显示连接mysql：too many connections，

a)，登录Mysql执行set GLOBAL max_connections=2000;设置最大连接数。MySQL参数最大连接数max_connections

b)，测试在mysql的my.ini中添加 max_connections没有效果。my.ini 要求是ANSI编码，编码不对的话 net start mysql 直接报错 error: Found option without preceding group in config file。

3，系统出错，请重试或联系系统负责人，官方说明：点击SampleApp进入配置界面，如果报这错误，请稍后几秒钟重试一下，因为通过Eureka注册的服务有一个刷新的延时。

a)，如果是本机测试用的：./demo.sh start 后一定不要更改网络环境！比如如果用的是wifi，start前用的是信号1，之后切换到了信号2，再访问8070的项目配置时就会报这个错误。检查方法是：./demo.sh start 看请求的8080端口前的ip是否是你当前ip或localhost，默认是localhost。

b)，如果你用了虚拟机、docker或云服务器，在前面过程4 中应修改 8080端口对应的ip

SAP .Net 调用RFC通用方法

C# SAP .Net Connector 3.0連接RFC示例

必备环境：

1，类库sapnco.dll、sapnco_utils.dll。可以通过官方下载安装取得，也可以直接从网上只下载这两个类库，还能直接从NuGet获取：Install-Package SAPDotNetConnector3 -Version 0.3.0。

2，Microsoft Visual C++ 2010 Redistributable Package，简称Microsoft Visual C++ 2010 。下载链接，可从控制面板查看已安装程序确认有没安装。Windows更新中可能已包含了Microsoft Visual C++ 2010，但不在已安装程序中显示。

步骤1：SAP定义RFC

步骤2：C#实现

a)：调用SAP RFC封装类：

namespace RFCLib
{
    //C#代码创建Sap连接对象的类SapConnection
    public class SapConnection : IDestinationConfiguration
    {
        RfcConfigParameters IDestinationConfiguration.GetParameters(string destinationName) //或 public  RfcConfigParameters GetParameters(string destinationName)
        {
            SAPClient sapClient;
            System.Xml.Serialization.XmlSerializer serializer = new System.Xml.Serialization.XmlSerializer(typeof(SAPClient));
            string sapClientSettingPath = System.AppDomain.CurrentDomain.BaseDirectory+ "SAPClientSetting.config";
            using (System.IO.FileStream fileStream = new System.IO.FileStream(sapClientSettingPath, System.IO.FileMode.Open))
            {
                sapClient = (SAPClient)serializer.Deserialize(fileStream);
            }
            return GetParameters(destinationName, sapClient);            
        }

        public RfcConfigParameters GetParameters(string destinationName, SAPClient sapInfo)
        {
            RfcConfigParameters conf = new RfcConfigParameters();
            if (destinationName == "NSP")//给连接SAP的对象命个名
            {
                //先添加必填参数       
                conf.Add(RfcConfigParameters.SystemNumber, sapInfo.SystemNumber);
                //conf.Add(RfcConfigParameters.SystemID, "");
                conf.Add(RfcConfigParameters.User, sapInfo.User);
                conf.Add(RfcConfigParameters.Password, sapInfo.Password);
                conf.Add(RfcConfigParameters.Client, sapInfo.Client);
                conf.Add(RfcConfigParameters.Language, sapInfo.Language);


                //添加可选参数（普通登陆参数）
                if (!string.IsNullOrEmpty(sapInfo.ApplicationServer))
                    conf.Add(RfcConfigParameters.AppServerHost, sapInfo.ApplicationServer);

                if (!string.IsNullOrEmpty(sapInfo.AppServerService))
                    conf.Add(RfcConfigParameters.AppServerService, sapInfo.AppServerService);

                //添加可选参数（服务器组参数）
                if (!string.IsNullOrEmpty(sapInfo.MessageServerHost))
                    conf.Add(RfcConfigParameters.MessageServerHost, sapInfo.MessageServerHost);

                if (!string.IsNullOrEmpty(sapInfo.MessageServerService))
                    conf.Add(RfcConfigParameters.MessageServerService, sapInfo.MessageServerService);

                if (!string.IsNullOrEmpty(sapInfo.LogonGroup))
                    conf.Add(RfcConfigParameters.LogonGroup, sapInfo.LogonGroup);

                if (!string.IsNullOrEmpty(sapInfo.SystemID))
                    conf.Add(RfcConfigParameters.SystemID, sapInfo.SystemID);
            }
            return conf;
        }
        public bool ChangeEventsSupported()
        {
            return true;
        }
        public event RfcDestinationManager.ConfigurationChangeHandler ConfigurationChanged;
    }

    //SAP连接参数类
    public class SAPClient
    {

        public string ApplicationServer { get; set; }   //应用服务器IP地址，如 10.88.88.88
        public string AppServerService { get; set; }
        public string Client { get; set; }              //sap客户端 如 100
        public string Language { get; set; }            //语言，如 ZH 或 EN
        public string LogonGroup { get; set; }          //登录组名
        public string MessageServerHost { get; set; }   //消息服务器IP地址 
        public string MessageServerService { get; set; }
        public string Password { get; set; }            //登录密码
        public string SystemID { get; set; }            //系统标识
        public string SystemNumber { get; set; }        //实例号，如 00
        public string User { get; set; }                //登录账号
    }


    //自定义的调用RFC的类
    public class NcoQueryRFC
    {
        //创建Sap连接对象的类SapConnection的实例global_dest，单例模式
        private static RfcDestination global_dest;
        public static RfcDestination SapConnInfo()
        {
            if (global_dest == null)
            {
                //SapConnection类定义见代码末
                SapConnection con= new SapConnection(); 
                RfcDestinationManager.RegisterDestinationConfiguration(con);
            }

            //这里定义
            global_dest = RfcDestinationManager.GetDestination("NSP");
            return global_dest;
        }


        //查询RFC的方法 
        //public static IRfcFunction ExcuteAndGetSAPFuntion(string funtionName,List<Dictionary<string,object>> functionparamsList)
        /// <summary>
        /// 调用RFC并获取SAP函数调用结果
        /// </summary>
        /// <param name="funtionName">函数名称</param>
        /// <param name="functionparamsList">函数所需参数</param>
        /// <returns>RFC调用结果</returns>
        static IRfcFunction ExcuteAndGetSAPFuntion(string funtionName, List<Dictionary<string, object>> functionparamsList)
        {
            RfcDestination dest = NcoQueryRFC.SapConnInfo();
            RfcRepository rfcrep = dest.Repository;
            IRfcFunction myfun = rfcrep.CreateFunction(funtionName); //RFC的名称
            foreach (Dictionary<string,Object> functionparams in functionparamsList)
            {
                foreach (var item in functionparams)
                {
                    myfun.SetValue(item.Key, item.Value);
                }
            }
            myfun.Invoke(dest);//调用
            return myfun;//直接返回function，取到的结果由调用者提取。
        }

        //查询RFC导出
        public static Dictionary<string, object> GetRFCExport(string funtionName, List<Dictionary<string, object>> functionparamsList, List<string> exportParams)
        {
            Dictionary<string, object> exports = new Dictionary<string, object>();
            IRfcFunction myfun = ExcuteAndGetSAPFuntion(funtionName,functionparamsList); //RFC的名称

            foreach (string exportParam in exportParams)
            {
                exports.Add(exportParam,myfun.GetValue(exportParam));
            }
            return exports;
        }
        
        /// <summary>
        /// 调用RFC,获取返回的table
        /// </summary>
        /// <param name="funtionName">函数名</param>
        /// <param name="functionparamsList">函数参数列表</param>
        /// <param name="tableName">RFC中定义的返回table的名称</param>
        /// <returns></returns>
        public static IRfcTable GetRFCTable(string funtionName, List<Dictionary<string, object>> functionparamsList, string tableName)
        {
            Dictionary<string, object> exports = new Dictionary<string, object>();
            IRfcFunction myfun = ExcuteAndGetSAPFuntion(funtionName, functionparamsList); //RFC的名称
            IRfcTable rfcTable = myfun.GetTable(tableName);
            return rfcTable;
        }
    }
}

100

101

102

103

104

105

106

107

108

109

110

111

112

113

114

115

116

117

118

119

120

121

122

123

124

125

126

127

128

129

130

131

132

133

134

135

136

137

138

139

140

141

142

143

144

145

146

147

148

149

150

151

namespace RFCLib

{

//C#代码创建Sap连接对象的类SapConnection

public class SapConnection : IDestinationConfiguration

{

RfcConfigParameters IDestinationConfiguration.GetParameters(string destinationName) //或 public RfcConfigParameters GetParameters(string destinationName)

{

SAPClient sapClient;

System.Xml.Serialization.XmlSerializer serializer = new System.Xml.Serialization.XmlSerializer(typeof(SAPClient));

string sapClientSettingPath = System.AppDomain.CurrentDomain.BaseDirectory+ "SAPClientSetting.config";

using (System.IO.FileStream fileStream = new System.IO.FileStream(sapClientSettingPath, System.IO.FileMode.Open))

{

sapClient = (SAPClient)serializer.Deserialize(fileStream);

}

return GetParameters(destinationName, sapClient);

}

public RfcConfigParameters GetParameters(string destinationName, SAPClient sapInfo)

{

RfcConfigParameters conf = new RfcConfigParameters();

if (destinationName == "NSP")//给连接SAP的对象命个名

{

//先添加必填参数

conf.Add(RfcConfigParameters.SystemNumber, sapInfo.SystemNumber);

//conf.Add(RfcConfigParameters.SystemID, "");

conf.Add(RfcConfigParameters.User, sapInfo.User);

conf.Add(RfcConfigParameters.Password, sapInfo.Password);

conf.Add(RfcConfigParameters.Client, sapInfo.Client);

conf.Add(RfcConfigParameters.Language, sapInfo.Language);

//添加可选参数（普通登陆参数）

if (!string.IsNullOrEmpty(sapInfo.ApplicationServer))

conf.Add(RfcConfigParameters.AppServerHost, sapInfo.ApplicationServer);

if (!string.IsNullOrEmpty(sapInfo.AppServerService))

conf.Add(RfcConfigParameters.AppServerService, sapInfo.AppServerService);

//添加可选参数（服务器组参数）

if (!string.IsNullOrEmpty(sapInfo.MessageServerHost))

conf.Add(RfcConfigParameters.MessageServerHost, sapInfo.MessageServerHost);

if (!string.IsNullOrEmpty(sapInfo.MessageServerService))

conf.Add(RfcConfigParameters.MessageServerService, sapInfo.MessageServerService);

if (!string.IsNullOrEmpty(sapInfo.LogonGroup))

conf.Add(RfcConfigParameters.LogonGroup, sapInfo.LogonGroup);

if (!string.IsNullOrEmpty(sapInfo.SystemID))

conf.Add(RfcConfigParameters.SystemID, sapInfo.SystemID);

}

return conf;

}

public bool ChangeEventsSupported()

{

return true;

}

public event RfcDestinationManager.ConfigurationChangeHandler ConfigurationChanged;

}

//SAP连接参数类

public class SAPClient

{

public string ApplicationServer { get; set; } //应用服务器IP地址，如 10.88.88.88

public string AppServerService { get; set; }

public string Client { get; set; } //sap客户端如 100

public string Language { get; set; } //语言，如 ZH 或 EN

public string LogonGroup { get; set; } //登录组名

public string MessageServerHost { get; set; } //消息服务器IP地址

public string MessageServerService { get; set; }

public string Password { get; set; } //登录密码

public string SystemID { get; set; } //系统标识

public string SystemNumber { get; set; } //实例号，如 00

public string User { get; set; } //登录账号

}

//自定义的调用RFC的类

public class NcoQueryRFC

{

//创建Sap连接对象的类SapConnection的实例global_dest，单例模式

private static RfcDestination global_dest;

public static RfcDestination SapConnInfo()

{

if (global_dest == null)

{

//SapConnection类定义见代码末

SapConnection con= new SapConnection();

RfcDestinationManager.RegisterDestinationConfiguration(con);

}

//这里定义

global_dest = RfcDestinationManager.GetDestination("NSP");

return global_dest;

}

//查询RFC的方法

//public static IRfcFunction ExcuteAndGetSAPFuntion(string funtionName,List<Dictionary<string,object>> functionparamsList)

/// <summary>

/// 调用RFC并获取SAP函数调用结果

/// </summary>

/// <param name="funtionName">函数名称</param>

/// <param name="functionparamsList">函数所需参数</param>

/// <returns>RFC调用结果</returns>

static IRfcFunction ExcuteAndGetSAPFuntion(string funtionName, List<Dictionary<string, object>> functionparamsList)

{

RfcDestination dest = NcoQueryRFC.SapConnInfo();

RfcRepository rfcrep = dest.Repository;

IRfcFunction myfun = rfcrep.CreateFunction(funtionName); //RFC的名称

foreach (Dictionary<string,Object> functionparams in functionparamsList)

{

foreach (var item in functionparams)

{

myfun.SetValue(item.Key, item.Value);

}

myfun.Invoke(dest);//调用

return myfun;//直接返回function，取到的结果由调用者提取。

}

//查询RFC导出

public static Dictionary<string, object> GetRFCExport(string funtionName, List<Dictionary<string, object>> functionparamsList, List<string> exportParams)

{

Dictionary<string, object> exports = new Dictionary<string, object>();

IRfcFunction myfun = ExcuteAndGetSAPFuntion(funtionName,functionparamsList); //RFC的名称

foreach (string exportParam in exportParams)

{

exports.Add(exportParam,myfun.GetValue(exportParam));

}

return exports;

}

/// <summary>

/// 调用RFC,获取返回的table

/// </summary>

/// <param name="funtionName">函数名</param>

/// <param name="functionparamsList">函数参数列表</param>

/// <param name="tableName">RFC中定义的返回table的名称</param>

/// <returns></returns>

public static IRfcTable GetRFCTable(string funtionName, List<Dictionary<string, object>> functionparamsList, string tableName)

{

Dictionary<string, object> exports = new Dictionary<string, object>();

IRfcFunction myfun = ExcuteAndGetSAPFuntion(funtionName, functionparamsList); //RFC的名称

IRfcTable rfcTable = myfun.GetTable(tableName);

return rfcTable;

}

b)：RFC返回Table转.Net平台DataTable对象。

        /// <summary>
        /// 将RFC返回的Table转换为.Net平台的DataTable对象
        /// </summary>
        /// <param name="rfcTable">RFC返回Table</param>
        /// <returns>转换后的.Net平台DataTable对象</returns>
        DataTable GetRFCData(IRfcTable rfcTable)
        {
            DataTable sourceTable = new DataTable();
            string columnName;
            //新增列
            for (int i = 0; i < rfcTable.Metadata.LineType.FieldCount; i++)
            {
                columnName = rfcTable.Metadata[i].Name;
                sourceTable.Columns.Add(columnName);
            }
            DataRow row;
            //新增行
            foreach (SAP.Middleware.Connector.IRfcStructure item in rfcTable)
            {
                row = sourceTable.NewRow();
                string cellValue;
                for (int i = 0; i < rfcTable.Metadata.LineType.FieldCount; i++)
                {
                    columnName = rfcTable.Metadata[i].Name;
                    cellValue = item.GetString(columnName); 
                    //NUM类型，去除前导0
                    if (rfcTable.Metadata[i].DataType == RfcDataType.NUM )
                    {
                        cellValue = Convert.ToInt32(item.GetString(columnName)).ToString();
                    }
                    row[columnName] = cellValue;
                }
                sourceTable.Rows.Add(row);
            }
            return sourceTable;
        }

/// <summary>

/// 将RFC返回的Table转换为.Net平台的DataTable对象

/// </summary>

/// <param name="rfcTable">RFC返回Table</param>

/// <returns>转换后的.Net平台DataTable对象</returns>

DataTable GetRFCData(IRfcTable rfcTable)

{

DataTable sourceTable = new DataTable();

string columnName;

//新增列

for (int i = 0; i < rfcTable.Metadata.LineType.FieldCount; i++)

{

columnName = rfcTable.Metadata[i].Name;

sourceTable.Columns.Add(columnName);

}

DataRow row;

//新增行

foreach (SAP.Middleware.Connector.IRfcStructure item in rfcTable)

{

row = sourceTable.NewRow();

string cellValue;

for (int i = 0; i < rfcTable.Metadata.LineType.FieldCount; i++)

{

columnName = rfcTable.Metadata[i].Name;

cellValue = item.GetString(columnName);

//NUM类型，去除前导0

if (rfcTable.Metadata[i].DataType == RfcDataType.NUM )

{

cellValue = Convert.ToInt32(item.GetString(columnName)).ToString();

}

row[columnName] = cellValue;

}

sourceTable.Rows.Add(row);

}

return sourceTable;

}

c)：C#通过封装类库调用RFC

/// <summary>
/// 从SAP根据料号及类别获取SAP图文档类别、编号、版本、名称
/// </summary>
/// <param name="part">料号</param>
/// <param name="sapDoctype">SAP类别代号</param>
///// <param name="code">返回结果状态码：0成功 1失败</param>
///// <param name="msg">返回结果描述</param>
/// <param name="result">返回结果</param>
[WebMethod(Description = "从SAP根据料号及类别获取图文档类别、编号、版本、名称")]
//public void GetPLMCADD_SAP(string part, string sapDoctype, ref string code,ref string msg,  ref object result)
public string GetPLMCADD_SAP(string part, string sapDoctype)
{

    #region 初始返回对象与参数检验
    SAPServiceResult sAPServiceResult = new SAPServiceResult()
            {
                Code = "1",
                Message = "未处理！",
                Data = null
            };
    if (string.IsNullOrEmpty(part) || string.IsNullOrEmpty(sapDoctype))
            {
                sAPServiceResult.Message = "缺少参数";
                return Newtonsoft.Json.JsonConvert.SerializeObject(sAPServiceResult, Newtonsoft.Json.Formatting.Indented);
            }
    else if (!RFCLib.RFC.SAPDocTypes.Split(',').Contains(sapDoctype))
    {
        sAPServiceResult.Message = $"类别{sapDoctype}不存在";
        return Newtonsoft.Json.JsonConvert.SerializeObject(sAPServiceResult, Newtonsoft.Json.Formatting.Indented);
    }
    #endregion

    List<Dictionary<string, object>> paramsList = new List<Dictionary<string, object>>();
    Dictionary<string, object> keyValuePairs2 = new Dictionary<string, object>() { { "IM_MATNR", part } };
    paramsList.Add(keyValuePairs2);
    //1，通过料号获取SAP图文档类别、编号、版本、名称
    string rfcTableName = RFCLib.RFC.sapRfcs.Where(x => x.Name == "ZPLM_MAT_LINK_DIRS_GET_MES").Take(1).Select(x => x.Table.Name).FirstOrDefault();
    IRfcTable rfcTable = RFCLib.NcoQueryRFC.GetRFCTable("ZPLM_MAT_LINK_DIRS_GET_MES", paramsList, rfcTableName);
    DataTable ZPLM_MAT_LINK_DIRS_GET_TableData = GetRFCData(rfcTable);
    DataRow row1 = ZPLM_MAT_LINK_DIRS_GET_TableData.AsEnumerable().Where(x => x["DOKAR"].ToString() == sapDoctype.Trim()).OrderByDescending(x => x["DOKVR"]).FirstOrDefault();
    object[] rowData = row1.ItemArray;//先将结果保存起来，否则Rows.Clear()后，row1会被清空。
    ZPLM_MAT_LINK_DIRS_GET_TableData.Rows.Clear();
    ZPLM_MAT_LINK_DIRS_GET_TableData.Rows.Add(rowData);
    sAPServiceResult.Code = "0";
    sAPServiceResult.Message = "ok";
    sAPServiceResult.Data = ZPLM_MAT_LINK_DIRS_GET_TableData;
    string jsonStr = Newtonsoft.Json.JsonConvert.SerializeObject(sAPServiceResult, Newtonsoft.Json.Formatting.Indented);
    return jsonStr;
}

/// <summary>
/// SAPService接口返回封装对象
/// </summary>
class SAPServiceResult
{
    /// <summary>
    /// 状态码：0执行成功，其他执行失败
    /// </summary>
    public string Code { get; set; }
    /// <summary>
    /// 说明
    /// </summary>
    public string Message { get; set; }
    /// <summary>
    /// 执行结果
    /// </summary>
    public object Data { get; set; }
}

/// <summary>

/// 从SAP根据料号及类别获取SAP图文档类别、编号、版本、名称

/// </summary>

/// <param name="part">料号</param>

/// <param name="sapDoctype">SAP类别代号</param>

///// <param name="code">返回结果状态码：0成功 1失败</param>

///// <param name="msg">返回结果描述</param>

/// <param name="result">返回结果</param>

[WebMethod(Description = "从SAP根据料号及类别获取图文档类别、编号、版本、名称")]

//public void GetPLMCADD_SAP(string part, string sapDoctype, ref string code,ref string msg, ref object result)

public string GetPLMCADD_SAP(string part, string sapDoctype)

{

#region 初始返回对象与参数检验

SAPServiceResult sAPServiceResult = new SAPServiceResult()

{

Code = "1",

Message = "未处理！",

Data = null

};

if (string.IsNullOrEmpty(part) || string.IsNullOrEmpty(sapDoctype))

{

sAPServiceResult.Message = "缺少参数";

return Newtonsoft.Json.JsonConvert.SerializeObject(sAPServiceResult, Newtonsoft.Json.Formatting.Indented);

}

else if (!RFCLib.RFC.SAPDocTypes.Split(',').Contains(sapDoctype))

{

sAPServiceResult.Message = $"类别{sapDoctype}不存在";

return Newtonsoft.Json.JsonConvert.SerializeObject(sAPServiceResult, Newtonsoft.Json.Formatting.Indented);

}

#endregion

List<Dictionary<string, object>> paramsList = new List<Dictionary<string, object>>();

Dictionary<string, object> keyValuePairs2 = new Dictionary<string, object>() { { "IM_MATNR", part } };

paramsList.Add(keyValuePairs2);

//1，通过料号获取SAP图文档类别、编号、版本、名称

string rfcTableName = RFCLib.RFC.sapRfcs.Where(x => x.Name == "ZPLM_MAT_LINK_DIRS_GET_MES").Take(1).Select(x => x.Table.Name).FirstOrDefault();

IRfcTable rfcTable = RFCLib.NcoQueryRFC.GetRFCTable("ZPLM_MAT_LINK_DIRS_GET_MES", paramsList, rfcTableName);

DataTable ZPLM_MAT_LINK_DIRS_GET_TableData = GetRFCData(rfcTable);

DataRow row1 = ZPLM_MAT_LINK_DIRS_GET_TableData.AsEnumerable().Where(x => x["DOKAR"].ToString() == sapDoctype.Trim()).OrderByDescending(x => x["DOKVR"]).FirstOrDefault();

object[] rowData = row1.ItemArray;//先将结果保存起来，否则Rows.Clear()后，row1会被清空。

ZPLM_MAT_LINK_DIRS_GET_TableData.Rows.Clear();

ZPLM_MAT_LINK_DIRS_GET_TableData.Rows.Add(rowData);

sAPServiceResult.Code = "0";

sAPServiceResult.Message = "ok";

sAPServiceResult.Data = ZPLM_MAT_LINK_DIRS_GET_TableData;

string jsonStr = Newtonsoft.Json.JsonConvert.SerializeObject(sAPServiceResult, Newtonsoft.Json.Formatting.Indented);

return jsonStr;

}

/// <summary>

/// SAPService接口返回封装对象

/// </summary>

class SAPServiceResult

{

/// <summary>

/// 状态码：0执行成功，其他执行失败

/// </summary>

public string Code { get; set; }

/// <summary>

/// 说明

/// </summary>

public string Message { get; set; }

/// <summary>

/// 执行结果

/// </summary>

public object Data { get; set; }

}

selet2 vue2实现下拉级联

功能：起运港与目的港来源于一张表，两个栏位为多对多关系，即1个起运港可以对应多个目的港，1个目的港也可以对应多个起运港。两个栏位下拉选项互为限制条件。

难点：select2组件change事件要能与父级(即Vue)通信，并更新起运港/目的港拉下选项。vue不允许子组件更新父组价传入的对象，即只允许数据单向流入(要用$emit。测试可传v-model的input的value，传递其他父级传入的对象提示不允许重写父级变量)。

方案：vue通过v-mode将选中的值传入select组件的props对象中，select中监听input change事件，将选中的值通过$emit传回父组件，在父级别(即vue)监听(watch)选中的值，如果有变更，就去更新对方的下拉选项访问(例如：监听起运港，如果选了1，就去更新目的港绑定的下拉选项)

实现：

slect2组件定义：

Vue.component('select2', {
    props: ['value'],
    template: `
    <select class="selector select2bs4" v-bind:name="name" >
        <slot></slot>
    </select>
    `,
    mounted: function () {
        var vm = this;

        $(this.$el)
            // init select2
            .select2({ data: this.options })
            .val(this.value)
            .trigger('change')
            // emit event on change.
            .on('change', function () {
                debugger;
                vm.$emit('input', this.value)

            })
    },
    watch: {
        value: function (value) {
            // update value
            $(this.$el)
                .val(value)
                .trigger('change');
        },
        options: function (options) {
            // update options
            $(this.$el).empty().select2({ data: options })
        },
        pods: function(pods){
            this.pods=pods;
        }
    },
    destroyed: function () {
        $(this.$el).off().select2('destroy')
    }
})

Vue.component('select2', {

props: ['value'],

template: `

</select>

mounted: function () {

var vm = this;

$(this.$el)

// init select2

.select2({ data: this.options })

.val(this.value)

.trigger('change')

// emit event on change.

.on('change', function () {

debugger;

vm.$emit('input', this.value)

})

watch: {

value: function (value) {

// update value

$(this.$el)

.val(value)

.trigger('change');

options: function (options) {

// update options

$(this.$el).empty().select2({ data: options })

pods: function(pods){

this.pods=pods;

}

destroyed: function () {

$(this.$el).off().select2('destroy')

}

})

html中使用select2组件：

 <div class="form-row align-items-center" id ="app">

                    <div class="input-group col-md-5 col-sm-5">
                      <div class="input-group-prepend">
                        <label class="input-group-text" for="inputGroupSelect01">起运港</label>
                      </div>
                      <select2 :options="pols" v-model="targetPol" name="pol" id="poFrom">
                        <!-- <option selected>请选择</option> -->
                        <option v-bind:value="item" v-for="item in pols">{{item}}
                      </select2>
                    </div>

                    <div class="input-group col-md-5 col-sm-5">
                      <div class="input-group-prepend">
                        <label class="input-group-text" for="inputGroupSelect01">目的港</label>
                      </div>
                      <select2 :options="pods" v-model="targetPod" name="pod" id="poTo">
                        <!--  <option selected>请选择</option> -->
                        <option v-bind:value="item" v-for="item in pods">{{item}}
                      </select2>
                    </div>

                    <div class="input-group col-md-1 col-sm-1">
                      <div class="input-group-prepend">
                        <span v-on:click="clearSearch()" class="fas fa-redo" title="重置"></span>
                      </div>
                    </div>
                    <div class="input-group col-md-1 col-sm-1">
                      <div class="input-group-prepend">
                        <input type="button" v-on:click="search()" class="btn btn-primary " value="查询"></input>
                      </div>
                    </div>

                  </div>
  <script>
    $(function () {
      //Initialize Select2 Elements
      $('.select2bs4').select2({
        theme: 'bootstrap4'
      })
    })
  </script>

</div>

<option v-bind:value="item" v-for="item in pols">{{item}}

</select2>

</div>

</div>

<option v-bind:value="item" v-for="item in pods">{{item}}

</select2>

</div>

</div>

</div>

$(function () {

//Initialize Select2 Elements

$('.select2bs4').select2({

theme: 'bootstrap4'

})

</script>

vue实现：

var app = new Vue({
    el: '#app',
    //template: '#demo-template',
    data: {
        pos: [
            { "from": "1", "to": "11" }, { "from": "1", "to": "12" }, { "from": "1", "to": "13" }, { "from": "1", "to": "14" }, { "from": "101", "to": "14" }, { "from": "102", "to": "13" }
            , { "from": "2", "to": "21" }, { "from": "2", "to": "22" }
            , { "from": "3", "to": "31" }, { "from": "3", "to": "32" }, { "from": "3", "to": "33" }
            , { "from": "4", "to": "41" }
        ],
        pols: [],
        pods: [],
        showPOL: true,
        showPOD: true,
        targetPol: -1,
        targetPod: -1
    },
    mounted: function () {
        //1，载入时实现
        var polsSet = new Set()
        var podsSet = new Set()
        for (var item in this.pos) {
            polsSet.add(this.pos[item].from);
            podsSet.add(this.pos[item].to);
        }
         this.pols = Array.from(polsSet);
        this.pods = Array.from(podsSet); 
    },
    watch: {
        //监听起运港，更新目的港
        targetPol: function (val) {
            var podsSet = new Set()
             this.pos.forEach(function (item, index) {
                    if (item.from == val) {
                        podsSet.add(item.to);
                    }
                })
                $("#poTo").empty();//先清空所有数据，否则带出的下拉值会有重复复
            $('#poTo').select2({
                data:Array.from(podsSet),
                theme: 'bootstrap4'
            }); 
        },
        //监听目的港，更新起运港
        targetPod: function (val) {
            var poddSet = new Set()
             this.pos.forEach(function (item, index) {
                    if (item.to == val) {
                        poddSet.add(item.from);
                    }
                })
                $("#poFrom").empty();//先清空所有数据，否则带出的下拉值会有重复复
            $('#poFrom').select2({
                data:Array.from(poddSet),
                theme: 'bootstrap4'
            }); 
        }
        },
    methods: {
        search: function (obj, evt) {
        },
        clearSearch: function (obj, evt) {
            debugger;
            //重新载入起始港与目的港
            $("#poFrom").empty();//先清空所有数据，否则带出的下拉值会有重复复
            $('#poFrom').select2({
                data:this.pols,
                theme: 'bootstrap4'
            }); 
            $("#poTo").empty();//先清空所有数据，否则带出的下拉值会有重复复
            $('#poTo').select2({
                data:this.pods,
                theme: 'bootstrap4'
            }); 

        }
    }
});

var app = new Vue({

el: '#app',

//template: '#demo-template',

data: {

pos: [

{ "from": "1", "to": "11" }, { "from": "1", "to": "12" }, { "from": "1", "to": "13" }, { "from": "1", "to": "14" }, { "from": "101", "to": "14" }, { "from": "102", "to": "13" }

, { "from": "2", "to": "21" }, { "from": "2", "to": "22" }

, { "from": "3", "to": "31" }, { "from": "3", "to": "32" }, { "from": "3", "to": "33" }

, { "from": "4", "to": "41" }

pols: [],

pods: [],

showPOL: true,

showPOD: true,

targetPol: -1,

targetPod: -1

mounted: function () {

//1，载入时实现

var polsSet = new Set()

var podsSet = new Set()

for (var item in this.pos) {

polsSet.add(this.pos[item].from);

podsSet.add(this.pos[item].to);

}

this.pols = Array.from(polsSet);

this.pods = Array.from(podsSet);

watch: {

//监听起运港，更新目的港

targetPol: function (val) {

var podsSet = new Set()

this.pos.forEach(function (item, index) {

if (item.from == val) {

podsSet.add(item.to);

}

})

$("#poTo").empty();//先清空所有数据，否则带出的下拉值会有重复复

$('#poTo').select2({

data:Array.from(podsSet),

theme: 'bootstrap4'

});

//监听目的港，更新起运港

targetPod: function (val) {

var poddSet = new Set()

this.pos.forEach(function (item, index) {

if (item.to == val) {

poddSet.add(item.from);

}

})

$("#poFrom").empty();//先清空所有数据，否则带出的下拉值会有重复复

$('#poFrom').select2({

data:Array.from(poddSet),

theme: 'bootstrap4'

});

}

methods: {

search: function (obj, evt) {

clearSearch: function (obj, evt) {

debugger;

//重新载入起始港与目的港

$("#poFrom").empty();//先清空所有数据，否则带出的下拉值会有重复复

$('#poFrom').select2({

data:this.pols,

theme: 'bootstrap4'

});

$("#poTo").empty();//先清空所有数据，否则带出的下拉值会有重复复

$('#poTo').select2({

data:this.pods,

theme: 'bootstrap4'

});

}

});

Nginx Docker方式部署ASP.NET Core项目

前述：

凡是基于http请求的的项目，都需要有有一个server以提供对client(UserAgent)的请求做处理并相应。也就是要有个HttpServer，也就是web服务器。(此处的web服务器是指提供处理http请求软件，非实体主机。web主机亦称作web服务器，此处服务器只实体主机。不要混淆)

web服务器：在Windows平台通常都是以IIS作为担当，在Linux上则通常是Nginx、Apache、TomCat。

ASP.Net Core项目：asp.net core 内部使用的是Kestrel作为web服务器，本地项目调试没有任何问题，但部署到Web服务器上，是无法直接被外部网络访问的，因为如果没有对Kestrel配置就不提供对外部访问的支持(待查证)。

部署：

Windows IIS上部署：参考官网步骤使用 IIS 在 Windows 上托管 ASP.NET Core ，关键步骤就是安装 .NET Core 托管捆绑包，按步骤，下载并安装项目引用的netcore版本的runtime，并在IIS新建无托管的应用程序池，并为网站或虚拟应用程序绑定此池。

Linux Nginx上部署：参考官网使用 Nginx 在 Linux 上托管 ASP.NET Core ，关键点：1，必须在Startup.Configure中配置支持反省代理 2，在/etc/nginx/sites-available/default默认为新增server节点，配置反向代理(实际就是讲Nginx监听的外部访问端口映射到 ASP.Net.Core项目的端口：默认5000端口)

最后：在Linux上 Nginx Docker方式部署ASP.NET Core项目

参考如何用一台服务器，部署多个不同的 WEB 项目 (use nginx in docker)

步骤：

1，下载并安装对应的Linux版本netcore运行时

2，安装Docker，官网链接

3，安装Nginx(Docker方式)，代替直接在主机上安装Nginx：条件建立好~/nginx-reverse-proxy文件夹，及www conf logs，用于将本机(host)路径与Docker中Nginx html、nginx.conf、log关联，也就是挂载，也就是docker说的卷(Volume)，如此如果对其中的文件做了修改 Nginx的Docker容器每次启动都都会加重最新的。

docker run -d -p 80:80 --name nginx-reverse-proxy -v ~/nginx-reverse-proxy/www:/usr/share/nginx/html -v ~/nginx-reverse-proxy/conf/nginx.conf:/etc/nginx/nginx.conf -v ~/nginx-reverse-proxy/logs:/var/log/nginx nginx

1	docker run -d -p 80:80 --name nginx-reverse-proxy -v ~/nginx-reverse-proxy/www:/usr/share/nginx/html -v ~/nginx-reverse-proxy/conf/nginx.conf:/etc/nginx/nginx.conf -v ~/nginx-reverse-proxy/logs:/var/log/nginx nginx

4，步骤3启动的Nginx，Docker中的80端口映射为了Host的80端口，如此，效果就同主机上(Host)安装了Nginx。

5，之后就是修改映射到host上的配置文件修改conf/nginx.conf ，添加反向代理的配置(在Nginx配置文件配置asp.net core项目Kestrel使用的端口map到的主机端口，外部网络就可以通过此端口进行访问了)。

下面的命令就是将host的100端口映射到另一个Nginx容器的80端口。反向代理配置应将项目Kestrel端口映射为Host的100端口。外部网络通过主机 ip:100或域名的方式就可以访问项目了。

docker run -d -p 100:80 --name nginx-cms -v ~/nginx-cms/www:/usr/share/nginx/html -v ~/nginx-cms/conf/nginx.conf:/etc/nginx/nginx.conf -v ~/nginx-cms/logs:/var/log/nginx nginx

				1

						docker run -d -p 100:80 --name nginx-cms -v ~/nginx-cms/www:/usr/share/nginx/html -v ~/nginx-cms/conf/nginx.conf:/etc/nginx/nginx.conf -v ~/nginx-cms/logs:/var/log/nginx nginx

WebSocket应用实例–进度条实现

应用背景：

系统新增资料批量上传功能，用户再上传过程中，不知道上传进度，等待时间过长会误以为系统导入异常而关闭页面，重新导入，可能出现资料重复的问题。为此，需要提供类似文件上传进度将执行进度回复给前端页面的方案。

消息从服务端客户端主动推送到客户端，最直接的方案是使用WebSocke(可以双向通信就行)。感觉是有点大材小用了。

具体实现

a，页面加载时与WebSocket服务端建立连接

b，服务端接收连接请求并记录下客户端socket连接

c，执行导入

d，服务端将进度返回前端(当前记录行/总记录行数)

e，前端解析

1，前端：

<script src="~/Scripts/jquery-1.6.4.js"></script>
<script type="text/javascript">
    var ws;
    $(
        function () {
            debugger;
            ws = new WebSocket("ws://" + window.location.hostname + ":" + window.location.port + "/plmimport/Home/WSChat?userid=" + $('#userid').val());
            ws.onopen = function () {
                //$("#messageSpan").text("Connected!");
                console.log("Connected!");
            };
            ws.onmessage = function (result) {
                //$("#messageSpan").text(result.data);
                $("#process").val(result.data.split('/')[0]);
                $("#process")[0].setAttribute("max", result.data.split('/')[1]);
                $("#processText").text(result.data);
                console.log(result.data);
            };
            ws.onerror = function (error) {
                //$("#messageSpan").text(error.data);
                console.log(error.data);
            };
            ws.onclose = function () {
                //$("#messageSpan").text("Disconnected!");
                console.log("Disconnected!");
            };
            
            $("#btnImport").click(function () {
                $(this).slideUp("slow");
                $("#process").show("slow");//.toggle("hidden");
                $("#p1").text("正在执行，请勿关闭当前页面！");
                $.ajax({
                    url: '/plmimport/home/index',
                    type: 'POST',
                    cache: false,
                    data: new FormData($('#uploadForm')[0]),
                    processData: false,
                    contentType: false
                }).done(function (res) {
                    $("#p1").text(res);
                    $("#btnImport").show("slow");
                }).fail(function (res) {
                    $("#p1").text(res);
                });
            });
        }
    );
</script>
--===============
<body>
    <div style="display:none;border: 1px solid #C8DBD3; padding: 8px; line-height: 30px; height:55px; background:url(../../Images/bg_odv.png);">
    </div>
    <input type="text" id="userid" value="@ViewBag.UserId" hidden />
    @*@using (Html.BeginForm("Index", "Home", FormMethod.Post, new { enctype = "multipart/form-data", id = "form1" }))
    {*@
        <form id="uploadForm" enctype="multipart/form-data">
            <h2>料件导入(Excel)</h2>
            <span style="color:red">@ViewBag.PartTemplateInfo</span>
            <div>
                <fieldset id="myfieldset">
                    <legend>帮助 </legend>
                    <p style="color: Red; text-align: left;">
                        @Html.ActionLink("模版下载", "GetFile", new { down = "template" })
                    </p>
                </fieldset>
            </div>
            <div style="margin-top: 20px;">
                <fieldset id="myfieldset2">
                    <legend>导入信息提示区</legend>
                    @*<p id="" style="color: Red; text-align:left;">@ViewBag.error</p>*@
                    <div>
                        <progress id="process" value="1" max="100" hidden></progress>
                        <label id="processText"></label>
                    </div>
                    <p id="p1" style="color: Red; text-align:left;">@ViewBag.error</p>
                </fieldset>
            </div>
            <div style="margin-top: 20px;">
                <fieldset id="myfieldset1">
                    <legend>导入操作</legend>
                    <p>选择文件：<input id="FileUpload" type="file" name="files" style="width: 250px; height: 28px;background: White" class="easyui-validatebox" /></p>
                    <p>
                        <input id="btnImport" type="button" value="执行导入" style="width: 100px; height: 28px;" />
                    </p>
                </fieldset>
            </div>
        </form>
            @* } *@
    </body>

var ws;

function () {

debugger;

ws = new WebSocket("ws://" + window.location.hostname + ":" + window.location.port + "/plmimport/Home/WSChat?userid=" + $('#userid').val());

ws.onopen = function () {

//$("#messageSpan").text("Connected!");

console.log("Connected!");

};

ws.onmessage = function (result) {

//$("#messageSpan").text(result.data);

$("#process").val(result.data.split('/')[0]);

$("#process")[0].setAttribute("max", result.data.split('/')[1]);

$("#processText").text(result.data);

console.log(result.data);

};

ws.onerror = function (error) {

//$("#messageSpan").text(error.data);

console.log(error.data);

};

ws.onclose = function () {

//$("#messageSpan").text("Disconnected!");

console.log("Disconnected!");

};

$("#btnImport").click(function () {

$(this).slideUp("slow");

$("#process").show("slow");//.toggle("hidden");

$("#p1").text("正在执行，请勿关闭当前页面！");

$.ajax({

url: '/plmimport/home/index',

type: 'POST',

cache: false,

data: new FormData($('#uploadForm')[0]),

processData: false,

contentType: false

}).done(function (res) {

$("#p1").text(res);

$("#btnImport").show("slow");

}).fail(function (res) {

$("#p1").text(res);

});

}

);

</script>

--===============

<body>

</div>

@*@using (Html.BeginForm("Index", "Home", FormMethod.Post, new { enctype = "multipart/form-data", id = "form1" }))

{*@

<h2>料件导入(Excel)</h2>

<span style="color:red">@ViewBag.PartTemplateInfo</span>

<div>

@Html.ActionLink("模版下载", "GetFile", new { down = "template" })

</p>

</fieldset>

</div>

<legend>导入信息提示区</legend>

@*<p id="" style="color: Red; text-align:left;">@ViewBag.error</p>*@

<div>

</div>

<p id="p1" style="color: Red; text-align:left;">@ViewBag.error</p>

</fieldset>

</div>

<p>

</p>

</fieldset>

</div>

</form>

@* } *@

</body>

2，后段实现：

#region 使用WebSocket实现消息推送
private static Dictionary<string, System.Net.WebSockets.WebSocket> CONN_POOL = new Dictionary<string, System.Net.WebSockets.WebSocket>();
public void WSChat()
{
    if (HttpContext.IsWebSocketRequest)
    {
        HttpContext.AcceptWebSocketRequest(ProcessWSChat);
    }
}
async System.Threading.Tasks.Task ProcessWSChat(System.Web.WebSockets.AspNetWebSocketContext context)
        {
            string user = context.QueryString["userid"]?.ToString();
            if (string.IsNullOrEmpty(user))
            {
                return;
            }
            System.Net.WebSockets.WebSocket ws = context.WebSocket;

            if (CONN_POOL.Keys.Contains(user))
            {
                if (CONN_POOL[user] != ws)
                {
                    CONN_POOL[user] = ws;
                }
            }
            else
            {
                CONN_POOL.Add(user, ws);
            }
            while (true)
            {
                if (ws.State == System.Net.WebSockets.WebSocketState.Open)
                {
                    ArraySegment<byte> buffer = new ArraySegment<byte>(new byte[2048]);
                    System.Net.WebSockets.WebSocketReceiveResult result = await ws.ReceiveAsync(buffer, System.Threading.CancellationToken.None);
                    try
                    {
                        #region 连接关闭，删除连接池
                        if (ws.State != System.Net.WebSockets.WebSocketState.Open)
                        {
                            if (CONN_POOL.Keys.Contains(user))
                            {
                                CONN_POOL.Remove(user);
                            }
                            break;
                        }
                        #endregion
                    }
                    catch (Exception ex)
                    {
                        if (CONN_POOL.Keys.Contains(user))
                        {
                            CONN_POOL.Remove(user);
                        }
                    }
                }
                else
                {
                    //发送消息时已离线。退出
                    break;
                }

            }
        }

async private void SendMessageToClient(string message)
        {
            ///消息推送异常不抛错误。
            try
            {
                if (Session["plmUserid"] == null || !CONN_POOL.Keys.Contains(Session["plmUserid"].ToString()))
                {
                    return;
                }
                if (CONN_POOL.Keys.Contains(Session["plmUserid"].ToString()))
                {
                    if (CONN_POOL[Session["plmUserid"].ToString()].State == System.Net.WebSockets.WebSocketState.Open)
                    {
                        await CONN_POOL[Session["plmUserid"].ToString()].SendAsync(GetArrSegFromStr(message), System.Net.WebSockets.WebSocketMessageType.Text, true, System.Threading.CancellationToken.None);
                    }
                }
            }
            catch (Exception ex)
            {
            }
        }

/// <summary>
/// 字符串转ArraySegment<byte>，用于WebSocket发送消息
/// </summary>
/// <param name="text">要转换的文本</param>
/// <returns></returns>
ArraySegment<byte> GetArrSegFromStr(string text)
        {
            return new ArraySegment<byte>(System.Text.Encoding.UTF8.GetBytes(text));
        }
/// <summary>
/// ArraySegment<byte>转字符串，用于消息队列存储
/// </summary>
/// <param name="text">要转换的ArraySegment对象</param>
/// <returns></returns>
string GetStrFromArrSeg(ArraySegment<byte> arrSeg)
        {
            return System.Text.Encoding.UTF8.GetString(arrSeg.Array);
        }
#endregion
//导入执行
[HttpPost]
public async System.Threading.Tasks.Task<string> Index(HttpPostedFileBase filebase)
{

    //ViewBag.error = "【inn=null】创建对象失败，请联系资讯PLM Team";
    //return ViewBag.error;
   SendMessageToClient("10/50");
   System.Threading.Thread.Sleep(1000);
   endMessageToClient("20/50");
   System.Threading.Thread.Sleep(1000);
   SendMessageToClient("30/50");
   System.Threading.Thread.Sleep(1000);
   System.Threading.Thread.Sleep(1000);
   SendMessageToClient("40/50");
   System.Threading.Thread.Sleep(1000);
   SendMessageToClient("50/50");
   System.Threading.Thread.Sleep(1000);
   return null;
}

100

101

102

103

104

105

106

107

108

109

110

111

112

113

114

115

116

117

118

119

120

121

122

123

124

125

126

#region 使用WebSocket实现消息推送

private static Dictionary<string, System.Net.WebSockets.WebSocket> CONN_POOL = new Dictionary<string, System.Net.WebSockets.WebSocket>();

public void WSChat()

{

if (HttpContext.IsWebSocketRequest)

{

HttpContext.AcceptWebSocketRequest(ProcessWSChat);

}

async System.Threading.Tasks.Task ProcessWSChat(System.Web.WebSockets.AspNetWebSocketContext context)

{

string user = context.QueryString["userid"]?.ToString();

if (string.IsNullOrEmpty(user))

{

return;

}

System.Net.WebSockets.WebSocket ws = context.WebSocket;

if (CONN_POOL.Keys.Contains(user))

{

if (CONN_POOL[user] != ws)

{

CONN_POOL[user] = ws;

}

else

{

CONN_POOL.Add(user, ws);

}

while (true)

{

if (ws.State == System.Net.WebSockets.WebSocketState.Open)

{

ArraySegment<byte> buffer = new ArraySegment<byte>(new byte[2048]);

System.Net.WebSockets.WebSocketReceiveResult result = await ws.ReceiveAsync(buffer, System.Threading.CancellationToken.None);

try

{

#region 连接关闭，删除连接池

if (ws.State != System.Net.WebSockets.WebSocketState.Open)

{

if (CONN_POOL.Keys.Contains(user))

{

CONN_POOL.Remove(user);

}

break;

}

#endregion

}

catch (Exception ex)

{

if (CONN_POOL.Keys.Contains(user))

{

CONN_POOL.Remove(user);

}

else

{

//发送消息时已离线。退出

break;

}

async private void SendMessageToClient(string message)

{

///消息推送异常不抛错误。

try

{

if (Session["plmUserid"] == null || !CONN_POOL.Keys.Contains(Session["plmUserid"].ToString()))

{

return;

}

if (CONN_POOL.Keys.Contains(Session["plmUserid"].ToString()))

{

if (CONN_POOL[Session["plmUserid"].ToString()].State == System.Net.WebSockets.WebSocketState.Open)

{

await CONN_POOL[Session["plmUserid"].ToString()].SendAsync(GetArrSegFromStr(message), System.Net.WebSockets.WebSocketMessageType.Text, true, System.Threading.CancellationToken.None);

}

catch (Exception ex)

{

}

/// <summary>

/// 字符串转ArraySegment<byte>，用于WebSocket发送消息

/// </summary>

/// <param name="text">要转换的文本</param>

/// <returns></returns>

ArraySegment<byte> GetArrSegFromStr(string text)

{

return new ArraySegment<byte>(System.Text.Encoding.UTF8.GetBytes(text));

}

/// <summary>

/// ArraySegment<byte>转字符串，用于消息队列存储

/// </summary>

/// <param name="text">要转换的ArraySegment对象</param>

/// <returns></returns>

string GetStrFromArrSeg(ArraySegment<byte> arrSeg)

{

return System.Text.Encoding.UTF8.GetString(arrSeg.Array);

}

#endregion

//导入执行

[HttpPost]

public async System.Threading.Tasks.Task<string> Index(HttpPostedFileBase filebase)

{

//ViewBag.error = "【inn=null】创建对象失败，请联系资讯PLM Team";

//return ViewBag.error;

SendMessageToClient("10/50");