[Asp.net]SignalR實現實時日誌監控

時間 2019-11-20

標籤 asp.net asp signalr 實現實時日誌監控欄目 ASP 简体版

原文原文鏈接

摘要

昨天吃飯的時候，忽然想起來一個好玩的事，若是能有個頁面能夠實時的監控網站或者其餘類型的程序的日誌，其實也不錯。固然，網上也有不少成熟的相似的監控系統。就想着若是經過.net該如何實現？因此就在想，經過系統內部將消息推送到前端，.net中能夠經過pull或者push的方式，pull一般的作法就是ajax方式不停的請求一個接口，這種方式，不太理想。而後就在想如何經過服務端想客戶端推送消息。以前看到過SignalR方面的文章能夠實現push的功能，signalr也是第一次接觸，在這個網站http://www.asp.net/signalr看了一些文章。就本身動手作了這樣的日誌監控的demo。前端

一個簡單的例子

先上一段代碼，以下：ajax

該類是一個監控日誌文件是否變化的一個單例類。其中維護一個日誌隊列。app

    public class FileSystemWatcherSingle
    {
        public FileSystemWatcher wather;
        private static FileSystemWatcherSingle _instance;
        private static readonly object _objLock = new object();
        public Queue<Log> MyQueue;
        private string _watherFolderPath = Path.Combine(AppDomain.CurrentDomain.BaseDirectory, "Log");
        private FileSystemWatcherSingle()
        {
            if (MyQueue == null)
            {
                MyQueue = new Queue<Log>();
            }
            if (wather == null)
            {
                wather = new FileSystemWatcher();
                if (!Directory.Exists(_watherFolderPath))
                {
                    Directory.CreateDirectory(_watherFolderPath);
                }
                wather.Path = _watherFolderPath;
                wather.EnableRaisingEvents = true;
            }
        }

        public static FileSystemWatcherSingle CreateInstance()
        {
            if (_instance == null)
            {
                lock (_objLock)
                {
                    if (_instance == null)
                    {
                        _instance = new FileSystemWatcherSingle();
                    }
                }
            }
            return _instance;
        }
    }

寫日誌的操做asp.net

在寫入文件以前，將當前的日誌加入到日誌隊列裏面。dom

using Newtonsoft.Json;
using System;
using System.Collections.Generic;
using System.IO;
using System.Linq;
using System.Web;

namespace Wolfy.LogMonitor.Models
{
    public class LogHelper
    {
        public static void WriteLog(Log log)
        {
            string dir = Path.Combine(AppDomain.CurrentDomain.BaseDirectory, "Log");
            if (!Directory.Exists(dir))
            {
                Directory.CreateDirectory(dir);
            }
            string _watherFilePath = Path.Combine(dir, DateTime.Now.ToString("yyyy-MM-dd") + ".log");
            if (!File.Exists(_watherFilePath))
            {
                File.Create(_watherFilePath);
            }
            FileSystemWatcherSingle wather = FileSystemWatcherSingle.CreateInstance();
            wather.MyQueue.Enqueue(log);
            File.AppendAllText(_watherFilePath, string.Format("{0} {1}\r\n{2}", log.Type.ToString(), log.Dt, log.Content));            
        }
    }
}

LogHub類測試

須要安裝SignalR，在安裝完成時，有個Readme文件，根據裏面的提示，須要添加StartUp類，添加對應的owin程序集。網站

using Microsoft.Owin;
using Owin;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Web;
using Wolfy.LogMonitor.App_Start;
[assembly: OwinStartup(typeof(Startup))]
namespace Wolfy.LogMonitor.App_Start
{
    public class Startup
    {
        public void Configuration(IAppBuilder app)
        {
            app.MapSignalR();
        }
    }
}

LogHub繼承Hub類，並在這裏想全部客戶端推送消息。並在這裏面面爲文件監控類FileSystemWatcher註冊建立和Change事件。ui

using System;
using System.Collections.Generic;
using System.Linq;
using System.Web;
using Microsoft.AspNet.SignalR;
using Microsoft.AspNet.SignalR.Hubs;
using System.Timers;
using Newtonsoft.Json;

namespace Wolfy.LogMonitor.Models
{
    [HubName("logHub")]
    public class LogHub : Hub
    {
        private FileSystemWatcherSingle fileWather;
        public void Send(string name, string message)
        {
            // Call the addNewMessageToPage method to update clients.
            Clients.All.addNewMessageToPage(name, message);
        }

        public LogHub()
        {
            fileWather = FileSystemWatcherSingle.CreateInstance();
            fileWather.wather.Changed += wather_Changed;
            fileWather.wather.Created += wather_Created;
        }

        void wather_Created(object sender, System.IO.FileSystemEventArgs e)
        {
            this.Send("system", "建立文件:" + e.Name);
        }

        void wather_Changed(object sender, System.IO.FileSystemEventArgs e)
        {
            while (fileWather.MyQueue != null && fileWather.MyQueue.Count > 0)
            {
                Log log = fileWather.MyQueue.Dequeue();
                if (log != null)
                {
                    this.Send(log.Type.ToString(), JsonConvert.SerializeObject(log));
                }
            }
        }
    }
}

前端this

home：log展現的頁面。根據日誌類型爲該條日誌顯示不一樣的顏色。spa

@{
    ViewBag.Title = "Home";
}

<div id="container">
</div>

<script>
    $(function () {
        // Reference the auto-generated proxy for the hub.
        var log = $.connection.logHub;
        console.log(log);
        // Create a function that the hub can call back to display messages.
        log.client.addNewMessageToPage = function (name, message) {
            console.log(name);
            console.log(message);
            // Add the message to the page.
            if (name === "Info") {                
                $('#container').append('<p style="color:green;">' + message + '</p>');
            } else {
                $('#container').append('<p style="color:red;">' + message + '</p>');
            }
        };
        // Start the connection.
        $.connection.hub.start().done();
    });

</script>

LogController

Test頁面是一個測試頁面，經過不停的刷新寫入隨機類型的日誌。

using System;
using System.Collections.Generic;
using System.Linq;
using System.Web;
using System.Web.Mvc;
using Wolfy.LogMonitor.Models;

namespace Wolfy.LogMonitor.Controllers
{
    public class LogController : Controller
    {
        // GET: Log
        public ActionResult Home()
        {
            return View();
        }
        public ActionResult Test()
        {
            LogType[] logtypes = { LogType.Info, LogType.Error };
            Random r = new Random();
            int index = r.Next(0, 2);
            LogHelper.WriteLog(new Log { Content = "這是一第二天志", Dt = DateTime.Now, Type = logtypes[index] });
            return View();
        }
    }
}