HttpServer 类

public class HttpServer

Public Class HttpServer

public ref class HttpServer

type HttpServer =  class end

private HttpServer httpServer;                                                     // 当前的Web服务器，支持web api来通信的方式

private void Start( )
{
    // 启动web的服务器
    try
    {
        this.httpServer = new HttpServer( );
        this.httpServer.Start( 8000 );
    }
    catch (Exception ex)
    {
        Console.WriteLine( "Web服务器加载失败！" + ex.Message );
    }
}

// 调用start方法之后，我们打开浏览器，输入 http://127.0.0.1:8000 就可以看到如下的文本 "This is HslWebServer, Thank you for use!"
// After calling the start method, we open the browser and enter http://127.0.0.1:8000 to see the following text: "This is HslWebServer, Thank you for use!"

private HttpServer httpServer;                                                     // 当前的Web服务器，支持web api来通信的方式

private void Start( )
{
    // 启动web的服务器
    try
    {
        this.httpServer = new HttpServer( );
        this.httpServer.HandleRequestFunc = HandleRequest;
        this.httpServer.Start( 8000 );
    }
    catch (Exception ex)
    {
        Console.WriteLine( "Web服务器加载失败！" + ex.Message );
    }
}

private string HandleRequest( HttpListenerRequest request, HttpListenerResponse response, string data )
{
    if (request.HttpMethod == "GET")
    {
        return "This is Get Method";
    }
    else if (request.HttpMethod == "POST")
    {
        return "This is Post Method";
    }
    else
    {
        return string.Empty;
    }
}

private string HandleRequest( HttpListenerRequest request, HttpListenerResponse response, string data )
{
    if (request.HttpMethod == "GET")
    {
        if (request.RawUrl == "/GetA")
        {
            return "This is GetA Method";
        }
        else if (request.RawUrl == "/GetB")
        {
            return "This is GetB Method";
        }
        else
        {
            return "This is Notsupported Method";
        }
    }
    else if (request.HttpMethod == "POST")
    {
        if (request.RawUrl == "/PostA")
        {
            Console.WriteLine( data );   // data 就是post上来的数据信息
            return "OK";
        }
        return "This is Post Method";
    }
    else
    {
        return string.Empty;
    }
}

private string HandleRequest( HttpListenerRequest request, HttpListenerResponse response, string data )
{
    // 下面的对授权验证增加用户名和密码的操作，当使用浏览器登录的时候，会自动弹出输入用户名及密码的窗口
    // The following operation for adding a username and password for authorization verification will automatically pop up a window for 
    // entering the username and password when logging in with a browser.
    string[] values = request.Headers.GetValues( "Authorization" );
    if (values == null || values.Length < 1 || string.IsNullOrEmpty( values[0] ))
    {
        response.StatusCode = 401;
        response.AddHeader( "WWW-Authenticate", "Basic realm=\"Secure Area\"" );
        return "";
    }

    string base64String = values[0].Split( new char[] { ' ' }, StringSplitOptions.RemoveEmptyEntries )[1];
    string accountString = Encoding.UTF8.GetString( Convert.FromBase64String( base64String ) );
    string[] account = accountString.Split( new char[] { ':' }, StringSplitOptions.RemoveEmptyEntries );
    if (account.Length < 2)
    {
        response.StatusCode = 401;
        response.AddHeader( "WWW-Authenticate", "Basic realm=\"Secure Area\"" );
        return "";
    }

    // 此处假定用户名和密码限定了 admin 123456
    if (!(account[0] == "admin" && account[1] == "123456"))
    {
        response.StatusCode = 401;
        response.AddHeader( "WWW-Authenticate", "Basic realm=\"Secure Area\"" );
        return "";
    }

    if (request.HttpMethod == "GET")
    {
        if (request.RawUrl == "/GetA")
        {
            return "This is GetA Method";
        }
        else if (request.RawUrl == "/GetB")
        {
            return "This is GetB Method";
        }
        else
        {
            return "This is Notsupported Method";
        }
    }
    else if (request.HttpMethod == "POST")
    {
        if (request.RawUrl == "/PostA")
        {
            Console.WriteLine( data );   // data 就是post上来的数据信息
            return "OK";
        }
        return "This is Post Method";
    }
    else
    {
        return string.Empty;
    }
}

private string HandleRequest( HttpListenerRequest request, HttpListenerResponse response, string data )
{
    if (request.HttpMethod == "GET")
    {
        if (request.RawUrl == "/GetA") // 当浏览器浏览一个网页的时候，输入 http://127.0.0.1:6000/GetA 会显示网络内容
        {
            response.AddHeader( "Content-type", $"Content-Type: text/html; charset=utf-8" );
            return "<html><head><title>HslWebServer</title></head><body><p style=\"color: red\">这是一个测试的消息内容</p></body></html>";
        }
        else
        {
            return "This is Notsupported Method";
        }
    }
    else if (request.HttpMethod == "POST")
    {
        return "This is Post Method";
    }
    else
    {
        return string.Empty;
    }
}

private HttpServer httpServer;                                                     // 当前的Web服务器，支持web api来通信的方式

private void Start( )
{
    // 启动web的服务器
    try
    {
        this.httpServer = new HttpServer( );
        this.httpServer.RegisterHttpRpcApi( this );       // 将当前类的方法接口（带HslMqttApi特性）注册为RPC接口

        // 如果需要控制账户登录的情况，如果不需要，直接注释下面的三行代码
        this.httpServer.SetLoginAccessControl( 
            new HslCommunication.MQTT.MqttCredential[] {
                new HslCommunication.MQTT.MqttCredential("admin", "123456")} );


        // 启动服务
        this.httpServer.Start( 8000 );
    }
    catch (Exception ex)
    {
        Console.WriteLine( "Web服务器加载失败！" + ex.Message );
    }
}

[HslCommunication.Reflection.HslMqttApi(Description = "这是求加法结果的RPC接口", HttpMethod = "GET")]
public int Add( int a, int b )
{
    return a + b;
}

/// <summary>
/// 一个更高级的RPC接口，用来校验用户名，密码，并且返回是否校验成功的结果
/// </summary>
/// <param name="name">用户名</param>
/// <param name="password">密码</param>
/// <returns>是否校验成功的结果</returns>
[HslCommunication.Reflection.HslMqttApi( Description = "校验用户名，密码，并且返回是否校验成功的结果，name:用户名 password:密码", HttpMethod = "GET" )]
public HslCommunication.OperateResult<string> CheckAccount( string name, string password )
{
    if (name == null) return new HslCommunication.OperateResult<string>( "user name can not be null" );
    if (password == null) return new HslCommunication.OperateResult<string>( "pwd can not be null" );
    if (name == "admin" && password == "123456") return HslCommunication.OperateResult.CreateSuccessResult( "" );
    return new HslCommunication.OperateResult<string>( "account or pwd wrong" );
}

public class UserData
{
    public string Name { get; set; } = "Name";
    public string A { get; set; } = "A";
    public string B { get; set; } = "B";
}

/// <summary>
/// 甚至参数可以定义为自定义类型，不过需要确保可以从json转换，自定义类型的接口使用 POST 方式，更好的传参
/// 本接口示例就是回传用户的名字
/// </summary>
/// <param name="userData">用户对象</param>
/// <returns>返回用户的名称</returns>
[HslCommunication.Reflection.HslMqttApi( Description = "回传用户的名字，参数为 UserData 对象", HttpMethod = "POST" )]
public HslCommunication.OperateResult<string> GetName( UserData userData )
{
    return HslCommunication.OperateResult.CreateSuccessResult( userData.Name );
}


// 下面演示带安全策略的接口，我有一个接口是需要面向指定用户的，而不是所有用户都可以调用的
// 那么需要参考启动的时候进行账户检查，这里演示，只能 admin 账户可以调用下面的方法

/// <summary>
/// 这是一个计算数据的RPC接口
/// </summary>
/// <param name="sessionContext">会话内容</param>
/// <param name="a">参数a</param>
/// <param name="b">参数b</param>
/// <returns>返回计算结果</returns>
[HslCommunication.Reflection.HslMqttApi( Description = "这是一个计算数据的RPC接口，只能admin账户调用，a:参数a b:参数b", HttpMethod = "GET" )]
public HslCommunication.OperateResult<int> Calculate( HslCommunication.Core.ISessionContext sessionContext, int a, int b )
{
    if (sessionContext.UserName == "admin") return HslCommunication.OperateResult.CreateSuccessResult( a * b );
    return new HslCommunication.OperateResult<int>( "Not supported" );
}