使用SignalR实现比特币价格实时刷新

ASP.NET SignalR是微软支持的一个运行在 Dot NET 平台上的 HTML Websocket 框架。它出现的主要目的是实现服务器主动推送(Push)消息到客户端页面,这样客户端就不必重新发送请求或使用轮询技术来获取消息。SignalR提供用于连接管理(例如,连接和断开的事件),分组连接和授权、发送、监听等一些简单易用的API,目前API支持JavaScript和C#两个平台,我们可以在NuGet上面轻松获取这些SDK。

使用SignalR实现比特币价格实时刷新

创建一个Startup.cs类在系统启动时注册SignalR。

using Owin;
using Microsoft.Owin;
[assembly: OwinStartup(typeof(SignalRDemo.Startup))]
namespace SignalRDemo
{
public partial class Startup
{
public void Configuration(IAppBuilder app)
{
app.MapSignalR();
}
}
}

Hub提供与ASP.NET SignalR通信的连接,使您可以从一台服务器连接客户端,并从客户端到服务器进行远程过程调用(RPC)。在服务器代码中,你定义可以被客户端调用方法,并调用该客户端上运行的方法。在客户端代码中,你定义可以从服务器上调用的方法,并且调用服务器上运行的方法。

实现比特币价格实时刷新,则只需要服务器到客户端的调用,我在下述StockHub中,开了一个Timer,每间隔9s去OKCoin获取交易行情,并将数据返回(refresh)给所有用户(Clients),OKCoin平台的交易行情API返回格式为:{"ticker":{"buy":"4003.95","high":"4046.0","last":"4003.95","low":"3857.0","sell":"4007.06","vol":"50344.8216"}},包括了买卖价格、最高、最低、交易量等数据。

using Microsoft.AspNet.SignalR;
using Microsoft.AspNet.SignalR.Hubs;
using System.IO;
using System.Net;
using System.Threading; namespace SignalRDemo.Hubs
{
[HubName("stock")]
public class StockHub : Hub
{
private const string BTC_CNY = "https://www.okcoin.com/api/ticker.do"; private static Timer _timer; static StockHub()
{
_timer = new Timer(Refresh, null, , );
} private static void Refresh(object state)
{
GlobalHost.ConnectionManager.GetHubContext<StockHub>().Clients.All.refresh(GetData(BTC_CNY).Replace("ticker", "BTC"));
} private static string GetData(string url)
{
HttpWebRequest request = (HttpWebRequest)HttpWebRequest.Create(url);
using (HttpWebResponse response = (HttpWebResponse)request.GetResponse())
{
using (StreamReader reader = new StreamReader(response.GetResponseStream()))
{
return reader.ReadToEnd();
}
}
}
}
}

修改Default.aspx,引入jQuery和SignalR插件,创建一个refresh方法供StockHub回调使用,该方法在接收到到数据后插入表格(为演示价格变化过程,记录每一次更新,而不是修改价格)。

<asp:Content runat="server" ID="BodyContent" ContentPlaceHolderID="MainContent">
<!--Script references. -->
<script src="Scripts/jquery-1.8.2.min.js"></script>
<script src="Scripts/jquery.signalR-2.0.2.min.js"></script>
<script src="signalr/hubs"></script>
<script type="text/javascript">
$(function () {
$.connection.stock.client.refresh = function (data) {
var obj = eval('(' + data + ')');
var newRow = "<tr><td>" + obj.BTC.last + "</td><td>" + obj.BTC.buy + "</td><td>" + obj.BTC.sell + "</td><td>" + obj.BTC.high + "</td><td>" + obj.BTC.low + "</td><td>" + obj.BTC.vol + "</td></tr>";
//if ($("#stock tr").length >= 1) {
// $("#stock tr:gt(0)").remove();
//}
$("#stock tr:last").after(newRow);
};
$.connection.hub.start().done();
});
</script>
<table id="stock" style="width: 100%">
<tr>
<th>最近成交价</th>
<th>买一价</th>
<th>卖一价</th>
<th>最高</th>
<th>最低</th>
<th>成交量</th>
</tr>
</table>
</asp:Content>

自此,所有代码实现完毕,使用非常简单,CTRL+F5启动项目,最终效果如下:

使用SignalR实现比特币价格实时刷新

再来开发一个简单的WinForm客户端,实现WinForm客户端需要引入Microsoft ASP.NET SignalR .NET Client库。

使用SignalR实现比特币价格实时刷新

与JavaScript类似,依据地址声明一个HubConnection,在由其创建一个Client Hub Proxy,由Proxy注册refresh时间,供服务端回调。

namespace SignalR.Client
{
public partial class FrmMain2 : Form
{
private readonly HubConnection _hubConnection = new HubConnection("http://localhost:2041/signalr");
private readonly IHubProxy _buildingApiHubProxy; public FrmMain2()
{
InitializeComponent();
_buildingApiHubProxy = _hubConnection.CreateHubProxy("stock");
_buildingApiHubProxy.On("refresh",
data => this.refresh(data)
);
_hubConnection.Start().Wait();
} private void refresh(string data)
{
this.lblMessage.Text = data;
}
}
}

使用SignalR实现比特币价格实时刷新

上一篇:配置Tomcat的日志系统


下一篇:linux软件包管理(下)