دوره آموزشی SignalR به زبان فارسی

بسم الله الرحمن الرحیم

دوره  آموزشی SignalR به زبان فارسی

ایجاد پروژه با SignalR و SQLDepedency در  ASP.NET MVC

بخش اول
بخش دوم

بخش سوم

بخش چهارم

بخش پنجم- شروع ایجاد پروژه SignalR

بخش ششم - مروری بر مفاهیم SignalR

بخش هفتم- ایجاد پروژه Chat با SignalR

بخش هشتم - ایجاد پروژه Chat با SignalR در ASP.NET MVC

بخش نهم- ساخت یک Timer سمت سرور با SignalR

بخش دهم - آموزش ساخت یک پروژه SignalR با SQLDepedency در ASP.NET MVC

در این آموزش می خواهیم هر تغییری که در پایگاه داده Sql Server ( توسط change notification مشخص می شوند) ایجاد شده است را توسط SignalR در یک پروژه ASP.NET نمایش دهیم.  این کار توسط یک query notification dependency مابین یک برنامه و یک نسخه از SQL Server انجام می شود، شیی که این وظیفه را انجام میدهد SqlDependency نام دارد.در نظر داشته باشید که پایگاه داده شما توسط windows service در background بروز رسانی  وsynchronized  (همزمان) با برنامه شما می شود و برنامه شما اطلاعات را به صورت real time نمایش می دهد.

DB Settings
ما نیاز داریم Service Broker را بر روی پایگاه داده خود فعال کنیم، برای اینکار دستور زیر را اجرا کنید:
چک کردن سرویس:

SELECT name, is_broker_enabled FROM sys.databases

فعال کردن سرویس
ما باید در مجوزهای لازم را به IIS service account بدهیم تا query notification تایید شود:

ALTER DATABASE TechBrijDB SET ENABLE_BROKER
GO

در این مثال ما از جدول JobInfo استفاده می کنیم:

GRANT SUBSCRIBE QUERY NOTIFICATIONS TO “Domain\ASPNET”

Setup SqlDependency

من از ASP.NET Web API استفاده می کنم اما تنظیمات یکه انجام میدهیم مشابه تنظیمات پروژه MVC ASP.NET است.
در ابتدا connection string را در web.config تنظیم کنید:

<connectionStrings>
    <add name="DefaultConnection" providerName="System.Data.SqlClient" connectionString="Data Source=.\SQLExpress;Initial Catalog=TechBrijDB;Integrated Security=SSPI;" />
</connectionStrings>

در Global.asax، listener را فعال کنید:

protected void Application_Start()
{
        //...
        SqlDependency.Start(ConfigurationManager.ConnectionStrings["DefaultConnection"].ConnectionString);
}

در متد زیر باید listener را متوقف کنید

protected void Application_End()
      {
          SqlDependency.Stop(ConfigurationManager.ConnectionStrings["DefaultConnection"].ConnectionString);
      }

کلاس های JobInfo  و JobInfoRepository را اضافه کنید:

public class JobInfo {
  public int JobID { get; set; }
  public  string Name { get; set; }
  public  DateTime LastExecutionDate { get; set; }
  public  string Status { get; set; }
}
 
 public class JobInfoRepository {
 
    public IEnumerable<JobInfo> GetData()
    {
       
        using (var connection = new SqlConnection(ConfigurationManager.ConnectionStrings["DefaultConnection"].ConnectionString))
        {
            connection.Open();
            using (SqlCommand command = new SqlCommand(@"SELECT [JobID],[Name],[LastExecutionDate],[Status]
               FROM [dbo].[JobInfo]", connection))
            {
                // Make sure the command object does not already have
                // a notification object associated with it.
                command.Notification = null;
 
                SqlDependency dependency = new SqlDependency(command);
                dependency.OnChange += new OnChangeEventHandler(dependency_OnChange);
 
                if (connection.State == ConnectionState.Closed)
                    connection.Open();
 
                using (var reader = command.ExecuteReader())
                    return reader.Cast<IDataRecord>()
                        .Select(x => new JobInfo(){
                            JobID = x.GetInt32(0),
                            Name = x.GetString(1),
                            LastExecutionDate = x.GetDateTime(2), 
                            Status  = x.GetString(3) }).ToList();                           
                 
 
 
            }
        }       
    }
    private void dependency_OnChange(object sender, SqlNotificationEventArgs e)
    {           
        JobHub.Show();
    }
 
 
}

در کد بالا، در event مربوط به SqlDependency OnChange، ما متد JobHub را فراخوانی می کنیم تا اطلاعات درون grid بروز رسانی شود. در بخش بعد Hub خود را ایجاد خواهیم کرد.

SignalR

برای نصب کردن Microsoft ASP.NET SignalR باید از طریق Package Manager Console دستور زیر را اجرا کنید:

Install-Package Microsoft.AspNet.SignalR -Pre

حال در متد global.asax > Application_Start  کد زیر قبل از متد RouteConfig.RegisterRoutes اضافه کنید:

اگر نسخه ای که نصب می کنید SignalR 2 باشد نیازی به این کد نیست، با دستور بالا طبیعتا نسخه 2 نصب می شود.

RouteTable.Routes.MapHubs();

باید namespace زیر را اضافه کنید:

using Microsoft.AspNet.SignalR; 

بر روی پروژه راست کلیک کنید و گزینه Add new item > Select “SignalR Hub Class” را انتخاب و نام آن را JobHub انتخاب کنید. دستورات زیر را به کلاس ایجاد شده اضافه کنید:

using Microsoft.AspNet.SignalR.Hubs;
 
 public class JobHub : Hub
    {
        public static void Show()
        {
            IHubContext context = GlobalHost.ConnectionManager.GetHubContext<JobHub>();
            context.Clients.All.displayStatus();
        }
    }

در کنترلر پیش فرض (نام کنترلر ما valuecontroller است)، یک شی از JobInfoRepository ایجاد و درون اکشنGet ، متد GetData را فراخوانی کنید:

public class ValuesController : ApiController
   {
 
       JobInfoRepository objRepo = new JobInfoRepository();
 
 
       // GET api/values
       public IEnumerable<JobInfo> Get()
       {
           return objRepo.GetData();
       }
   }

برای سادگی، ما در همین برنامه خود web api را مقدار دهی می کنیم، یک action با نام Status در Home controller ایجاد کنید، حال یک View بدون layout برای آن ایجاد کنید:

@{
    Layout = null;
}
 
<!DOCTYPE html>
 
<html>
<head>
    <meta name="viewport" content="width=device-width" />
    <title>JobStatus</title>
    @Styles.Render("~/Content/css")
    @Scripts.Render("~/bundles/modernizr")
    @Scripts.Render("~/bundles/jquery")
    <script src="~/Scripts/jquery.signalR-1.0.0-rc1.min.js"></script>
    <script src="~/signalr/hubs" type="text/javascript"></script>
    <script type="text/javascript">
 
        $(function () {
 
            // Proxy created on the fly
            var job = $.connection.jobHub;
 
            // Declare a function on the job hub so the server can invoke it
            job.client.displayStatus = function () {
                getData();
            };
          
            // Start the connection
            $.connection.hub.start();
            getData();
        });
 
        function getData() {
            var $tbl = $('#tblJobInfo');
            $.ajax({
                url: '../api/values',
                type: 'GET',
                datatype: 'json',
                success: function (data) {
                    if (data.length > 0) {
                        $tbl.empty();
                        $tbl.append(' <tr><th>ID</th><th>Name</th><th>Last Executed Date</th><th>Status</th></tr>');
                        var rows = [];
                        for (var i = 0; i < data.length; i++) {
                            rows.push(' <tr><td>' + data[i].JobID + '</td><td>' + data[i].Name + '</td><td>' + data[i].LastExecutionDate.toString().substr(0,10) + '</td><td>' + data[i].Status + '</td></tr>');
                        }
                        $tbl.append(rows.join(''));
                    }
                }
            });
        }
    </script>
</head>
<body>
    <div>
        <table id="tblJobInfo" style="text-align:center;margin-left:10px">
        </table>
    </div>
</body>
</html>

URL زیر را Browse کنید و آن را تست کنید:

http://yourserver/app/home/status

در پایگاه داده اگر تغییری ایجاد شود، متد dependency_OnChange به صورت trigger عمل خواهد کرد و متد Show مربوط به signalR Hub را فراخوانی خواهد نمود. این اطلاع ساخت (notifies) و trigger متد displayStatus در سمت کلاینت برای بروزرسانی داده ها است.


اگر شما خطای Javascript، " TypeError: $.connection is undefined" را دریافت کردید، باید مسیر jquery.signalR را در script reference های خود چک کنید تا مطمئن شوید آدرس شما در صفحه HTML صحیح وارد شده است.
اگر شما خطای Javascript، " The connection to http://localhost … was interrupted while the page was loading " را دریفات کردید، شما باید jquery ajax url خود را در متد GetData چک کنید.

دانلود پروژه SignalR و SqlDepedency

دانلود دیتابیس پروژه SignalR و SqlDepedency