22

私はsignalRの調査を始めたばかりで、サーバーからすべてのクライアントにメッセージを送信できるようにしたいと考えています。

これが私のハブです

 using System;
using System.Collections.Generic;
using System.Linq;
using System.Web;
using SignalR;
using SignalR.Hubs;
using SignalR.Hosting.Common;
using SignalR.Hosting.AspNet;
using System.Threading.Tasks;

namespace MvcApplication1
{
    public class Chat : Hub
    {
        public void Send(String message)
        {
            // Call the addMessage methods on all clients
            Clients.addMessage(message);
        }
    }
}

これが私のクライアントページです

      <script type="text/javascript">

         $(function () {

             //Proxy created on the fly
             var chat = $.connection.chat;

             // Declare a function on the chat hub so the server can invoke it
             chat.addMessage = function (message) {
                 $("#messages").append("<li>" + message + "</li>");
             };

             $("#broadcast").click(function () {
                 // call the chat method on the server
                 chat.send($("#msg").val());
             });

             $.connection.hub.start();
         });
    </script>


}



<input type="text" id="msg" />
        <input type="button" id="broadcast" value="broadcast" />

        <ul id="messages" class="round">


        </ul>

これはすべて完璧に機能し、2つの異なるブラウザ間で「チャット」することができます。

次に実行したいのは、サーバーからすべてのクライアントへのメッセージを開始することです。

だから私はこれを試しました。

 using SignalR;
using System.Web.Http;
using System.Web.Mvc;
using System.Web.Optimization;
using System.Web.Routing;
using System;
using System.Web.Routing;
using SignalR;
using SignalR.Hubs;

namespace MvcApplication1
{
    // Note: For instructions on enabling IIS6 or IIS7 classic mode, 
    // visit http://go.microsoft.com/?LinkId=9394801

    public class MvcApplication : System.Web.HttpApplication
    {
        protected void Application_Start()
        {            
            var aTimer = new System.Timers.Timer(1000);

            aTimer.Elapsed += aTimer_Elapsed;
            aTimer.Interval = 3000;
            aTimer.Enabled = true;

            AreaRegistration.RegisterAllAreas();

            WebApiConfig.Register(GlobalConfiguration.Configuration);
            FilterConfig.RegisterGlobalFilters(GlobalFilters.Filters);
            RouteConfig.RegisterRoutes(RouteTable.Routes);
            BundleConfig.RegisterBundles(BundleTable.Bundles);
            AuthConfig.RegisterAuth();
        }

        void aTimer_Elapsed(object sender, System.Timers.ElapsedEventArgs e)
        {
            var context = GlobalHost.ConnectionManager.GetHubContext<Chat>();
            context.Clients.Send("Hello");      
        }
    }
}

これはうまくいかないようです。タイマーは機能します。「aTimer_Elapsed」イベントハンデラーは3秒ごとに実行されますが、チャットハブの「Send」メソッドは実行されません。

何か案は？

4

3 に答える 3

37

私はそれがすべきだと思います

 void aTimer_Elapsed(object sender, System.Timers.ElapsedEventArgs e)
    {
        var context = GlobalHost.ConnectionManager.GetHubContext<Chat>();
        context.Clients.All.addMessage("Hello");      
    }

代わりは。Sendを使用すると、クライアントがサーバーを呼び出すために使用するメソッドを呼び出すことになります。

于 2012-08-30T04:24:18.423 に答える
9

質問されてから何年も経ってこの質問に遭遇し、たまたま.NET 5.0（または同様のもの）を使用している場合は、クラスを提供しなくなったフレームワークを使用している可能性があるため、次のことが役立つ場合がありますGlobalHost。

.NET 5.0（および同様のもの）は依存性注入（DI）を多用しており、ここでも使用されているのは当然のことです。次のサンプルコードは、これを行う方法を示しています。クラスは使用しませんGlobalHost。

ChatHub次のようにクラスが与えられます：

   public class ChatHub : Hub
   {
      public async Task SendMessage(string user, string message)
      {
         await Clients.All.SendAsync("ReceiveMessage", user, message).ConfigureAwait(false);
      }
   }

クラスStartupで、次のコードスニペットに示されているように行を追加します。

   public class Startup
   {
      // other code omitted for brevity

      public void Configure(IApplicationBuilder app, IWebHostEnvironment env)
      {
         // other code omitted for brevity

         app.UseEndpoints(endpoints =>
         {
            endpoints.MapControllers();
            endpoints.MapHub<ChatHub>("/chatHub"); // <====== add this ======
         });

         // other code omitted for brevity
      }
   }

次に、SignalRメッセージにメッセージを送信するコントローラーで、ChatHubを依存関係として追加します。次の例は、コンストラクターインジェクションに対してこれを行う方法を示しています。

   public class WeatherForecastController : ControllerBase
   {
      private readonly IHubContext<ChatHub> _hubContext;

      public WeatherForecastController(
         IHubContext<ChatHub> hubContext, // <============ add this ==========
         ILogger<WeatherForecastController> logger)
      {
         _hubContext = hubContext;
         _logger = logger;
      }
      
      [HttpGet]
      public virtual async Task<IEnumerable<WeatherForecastModel>> Get()
      {
         var rng = new Random();
         WeatherForecastModel[] weatherForecastModels = Enumerable.Range(1, 5).Select(index => new WeatherForecastModel
         {
            Date = DateTime.Now.AddDays(index),
            TemperatureC = rng.Next(-20, 55),
            Summary = Summaries[rng.Next(Summaries.Length)],
         }).ToArray();

         // Notify connected SignalR clients with some data:
         await _hubContext.Clients.All.SendAsync("ReceiveMessage", "the weatherman", $" The temperature will be {weatherForecastModels[0].TemperatureC}").ConfigureAwait(false);

         return weatherForecastModels;
      }

      // other code omitted for brevity
   }

Get()この例は、メソッドでメッセージを送信する方法も示しています。await _hubContext.Clients.All.SendAsync( ... )

詳細については、Microsoftのドキュメントを参照してください。

于 2021-06-07T23:14:07.023 に答える
1

はい、その行を次のように設定する必要があります。

void aTimer_Elapsed(object sender, System.Timers.ElapsedEventArgs e)
    {
        var context = GlobalHost.ConnectionManager.GetHubContext<Chat>();
        context.Clients.All.addMessage("Hello");      
    }

ただし、これは途中であり、まだ機能しません。

あなたのJsであなたは書く必要があります：

$(function () {

//Proxy created on the fly
var chat = $.connection.chat;

// Declare a function on the chat hub so the server can invoke it
chat.client.addMessage = function (message) {
    $("#messages").append("<li>" + message + "</li>");
};

$("#broadcast").click(function () {
    // call the chat method on the server
    chat.client.addMessage($("#msg").val());
});

$.connection.hub.start();
});

これを追加chat.clientすると、サーバーが呼び出すクライアント側のハブメソッドが追加されます。

于 2016-09-28T09:44:06.723 に答える