SignalR Service
This example demonstrates real-time data update in a DataGrid bound to a SignalR service. Access to the service is configured in a CustomStore.
The CustomStore fetches the remote dataset at launch and keeps its local copy. Whenever the remote dataset changes, the server calls a client-side function that updates the local copy of the dataset (updateStockPrices in this demo). This function uses the store's push(changes) method.
For server-side configuration, refer to the ASP.NET MVC version of this demo.
For more information about integration with push services, refer to the following help topic: Integration with Push Services.
NOTE
Data used in this demo is for demonstration purposes only.
Feel free to share demo-related thoughts here.
If you have technical questions, please create a support ticket in the DevExpress Support Center.
If you have technical questions, please create a support ticket in the DevExpress Support Center.
Thank you!
We appreciate your feedback.
We appreciate your feedback.
<div ng-if="connectionStarted">
<dx-data-grid
id="gridContainer"
[dataSource]="dataSource"
[showBorders]="true"
[repaintChangesOnly]="true"
[highlightChanges]="true"
>
<dxi-column
dataField="lastUpdate"
dataType="date"
[width]="115"
format="longTime"
>
</dxi-column>
<dxi-column dataField="symbol"> </dxi-column>
<dxi-column
dataField="price"
dataType="number"
format="#0.####"
cellTemplate="priceCellTemplate"
>
</dxi-column>
<dxi-column
dataField="change"
dataType="number"
[width]="140"
format="#0.####"
cellTemplate="changeCellTemplate"
>
</dxi-column>
<dxi-column dataField="dayOpen" dataType="number" format="#0.####">
</dxi-column>
<dxi-column dataField="dayMin" dataType="number" format="#0.####">
</dxi-column>
<dxi-column dataField="dayMax" dataType="number" format="#0.####">
</dxi-column>
<div
*dxTemplate="let cell of 'priceCellTemplate'"
[class.inc]="cell.data.change > 0"
[class.dec]="cell.data.change < 0"
>
<span>{{ cell.text }}</span>
</div>
<div
*dxTemplate="let cell of 'changeCellTemplate'"
[class.inc]="cell.data.change > 0"
[class.dec]="cell.data.change < 0"
>
<span class="current-value">{{ cell.text }}</span>
<span class="arrow"></span>
<span class="diff">{{ cell.data.percentChange.toFixed(2) }}%</span>
</div>
</dx-data-grid>
</div>
import { NgModule, Component, enableProdMode } from '@angular/core';
import { BrowserModule } from '@angular/platform-browser';
import { platformBrowserDynamic } from '@angular/platform-browser-dynamic';
import { HubConnectionBuilder, HttpTransportType } from '@aspnet/signalr';
import { DxDataGridModule } from 'devextreme-angular';
import CustomStore from 'devextreme/data/custom_store';
if (!/localhost/.test(document.location.host)) {
enableProdMode();
}
@Component({
selector: 'demo-app',
templateUrl: 'app/app.component.html',
styleUrls: ['app/app.component.css'],
})
export class AppComponent {
dataSource: any;
connectionStarted: boolean;
constructor() {
this.connectionStarted = false;
const hubConnection = new HubConnectionBuilder()
.withUrl('https://js.devexpress.com/Demos/NetCore/liveUpdateSignalRHub', {
skipNegotiation: true,
transport: HttpTransportType.WebSockets,
})
.build();
const store = new CustomStore({
load: () => hubConnection.invoke('getAllStocks'),
key: 'symbol',
});
hubConnection
.start()
.then(() => {
hubConnection.on('updateStockPrice', (data: any) => {
store.push([{ type: 'update', key: data.symbol, data }]);
});
this.dataSource = store;
this.connectionStarted = true;
});
}
}
@NgModule({
imports: [
BrowserModule,
DxDataGridModule,
],
declarations: [AppComponent],
bootstrap: [AppComponent],
})
export class AppModule { }
platformBrowserDynamic().bootstrapModule(AppModule);
::ng-deep #gridContainer span.current-value {
display: inline-block;
margin-right: 5px;
}
::ng-deep #gridContainer span.diff {
width: 50px;
display: inline-block;
}
::ng-deep #gridContainer .inc {
color: #2ab71b;
}
::ng-deep #gridContainer .dec {
color: #f00;
}
::ng-deep #gridContainer .inc .arrow,
::ng-deep #gridContainer .dec .arrow {
display: inline-block;
height: 10px;
width: 10px;
background-repeat: no-repeat;
background-size: 10px 10px;
}
::ng-deep #gridContainer .inc .arrow {
background-image: url('data:image/png;base64,iVBORw0KGgoAAAANSUhEUgAAABQAAAAUCAYAAACNiR0NAAAABGdBTUEAAK/INwWK6QAAABl0RVh0U29mdHdhcmUAQWRvYmUgSW1hZ2VSZWFkeXHJZTwAAADKSURBVHjaYtTaLs1ABEiG0nPRJa56PEHhsxBhmCUQT4OyrwHxcXyKmQgYJgHE64CYDYrXQcXIMhCbAcgWkGzgNKh38QUB0QamIUUErkhKI9ZAGyCeTERkTYaqxWsgKA2txhdG6GGsvUNGGpeBRMUiGhCFGsqGzUBQQJsxkA5AemaiG5hDIBIIgQSgK0FmMDACs549kN5FZLjhA7+A2A2U9YSAOBeLAk4gnoBDczoOcSFGPIUDPxB/wCHHiKtwYGKgMhg1cBAaCBBgAJTUIL3ToPZfAAAAAElFTkSuQmCC');
}
::ng-deep #gridContainer .dec .arrow {
background-image: url('data:image/png;base64,iVBORw0KGgoAAAANSUhEUgAAABQAAAAUCAYAAACNiR0NAAAABGdBTUEAAK/INwWK6QAAABl0RVh0U29mdHdhcmUAQWRvYmUgSW1hZ2VSZWFkeXHJZTwAAADJSURBVHjaYvzPgBfgkhYA4o8QFahKmBioDEYNHIQGsgBxIBCLkqgvAYi/g1mMjMjir0EJzR6If/6HpChKMMgMe3DKBeIcKhiY8x/MYoDj+RQYNgdkGLqBbEB8kgzDToL1YjEQhKWB+BUJhj0H64Eahs1AELYhMpJ+gtUiGYbLQBBOI8LANLBaIg1kAAc0vkiAqSPBQFAkHcNi2DGoHMkGgrAENOCRI0ECRQ2JBoKwJTQCfkLZDPgMZPxPXN5NhtJzMSsJVBMAAgwAyWSY2svfmrwAAAAASUVORK5CYII=');
}
// In real applications, you should not transpile code in the browser.
// You can see how to create your own application with Angular and DevExtreme here:
// https://js.devexpress.com/Documentation/Guide/Angular_Components/Getting_Started/Create_a_DevExtreme_Application/
window.config = {
transpiler: 'ts',
typescriptOptions: {
module: 'system',
emitDecoratorMetadata: true,
experimentalDecorators: true,
},
meta: {
'typescript': {
'exports': 'ts',
},
'devextreme/localization.js': {
'esModule': true,
},
},
paths: {
'npm:': 'https://unpkg.com/',
},
map: {
'ts': 'npm:plugin-typescript@4.2.4/lib/plugin.js',
'typescript': 'npm:typescript@4.2.4/lib/typescript.js',
'@angular/core': 'npm:@angular/core@12.2.16',
'@angular/platform-browser': 'npm:@angular/platform-browser@12.2.16',
'@angular/platform-browser-dynamic': 'npm:@angular/platform-browser-dynamic@12.2.16',
'@angular/forms': 'npm:@angular/forms@12.2.16',
'@angular/common': 'npm:@angular/common@12.2.16',
'@angular/compiler': 'npm:@angular/compiler@12.2.16',
'tslib': 'npm:tslib@2.3.1/tslib.js',
'rxjs': 'npm:rxjs@7.5.3/dist/bundles/rxjs.umd.js',
'rxjs/operators': 'npm:rxjs@7.5.3/dist/cjs/operators/index.js',
'@aspnet/signalr': 'npm:@aspnet/signalr@1.0.0/dist/cjs/index.js',
'rrule': 'npm:rrule@2.6.4/dist/es5/rrule.js',
'luxon': 'npm:luxon@1.28.0/build/global/luxon.min.js',
'es6-object-assign': 'npm:es6-object-assign@1.1.0',
'devextreme': 'npm:devextreme@22.1.4/cjs',
'devextreme/bundles/dx.all': 'npm:devextreme@22.1.4/bundles/dx.all.js',
'jszip': 'npm:jszip@3.7.1/dist/jszip.min.js',
'devextreme-quill': 'npm:devextreme-quill@1.5.16/dist/dx-quill.min.js',
'devexpress-diagram': 'npm:devexpress-diagram@2.1.63',
'devexpress-gantt': 'npm:devexpress-gantt@4.1.32',
'devextreme-angular': 'npm:devextreme-angular@22.1.4',
'@devextreme/runtime': 'npm:@devextreme/runtime@3.0.7',
'inferno': 'npm:inferno@7.4.4/dist/inferno.min.js',
'inferno-compat': 'npm:inferno-compat@7.4.11/dist/inferno-compat.min.js',
'inferno-create-element': 'npm:inferno-create-element@7.4.11/dist/inferno-create-element.min.js',
'inferno-dom': 'npm:inferno-dom/dist/inferno-dom.min.js',
'inferno-hydrate': 'npm:inferno-hydrate@7.4.11/dist/inferno-hydrate.min.js',
'inferno-clone-vnode': 'npm:inferno-clone-vnode@7.4.11/dist/inferno-clone-vnode.min.js',
'inferno-create-class': 'npm:inferno-create-class@7.4.11/dist/inferno-create-class.min.js',
'inferno-extras': 'npm:inferno-extras@7.4.11/dist/inferno-extras.min.js',
},
packages: {
'app': {
main: './app.component.ts',
defaultExtension: 'ts',
},
'devextreme': {
defaultExtension: 'js',
},
'devextreme/events/utils': {
main: 'index',
},
'devextreme/events': {
main: 'index',
},
'es6-object-assign': {
main: './index.js',
defaultExtension: 'js',
},
'rxjs': {
defaultExtension: 'js',
},
'rxjs/operators': {
defaultExtension: 'js',
},
},
packageConfigPaths: [
'npm:@devextreme/*/package.json',
'npm:@devextreme/runtime@3.0.7/inferno/package.json',
'npm:@angular/*/package.json',
'npm:@angular/common@12.2.16/*/package.json',
'npm:rxjs@7.5.3/package.json',
'npm:rxjs@7.5.3/operators/package.json',
'npm:devextreme-angular@22.1.4/*/package.json',
'npm:devextreme-angular@22.1.4/ui/*/package.json',
'npm:devextreme-angular@22.1.4/package.json',
'npm:devexpress-diagram@2.1.63/package.json',
'npm:devexpress-gantt@4.1.32/package.json',
'npm:@aspnet/*/package.json',
],
};
System.config(window.config);
<!DOCTYPE html>
<html xmlns="http://www.w3.org/1999/xhtml">
<head>
<title>DevExtreme Demo</title>
<meta http-equiv="X-UA-Compatible" content="IE=edge" />
<meta http-equiv="Content-Type" content="text/html; charset=utf-8" />
<meta name="viewport" content="width=device-width, initial-scale=1.0, maximum-scale=1.0" />
<link rel="stylesheet" type="text/css" href="https://cdn3.devexpress.com/jslib/22.1.4/css/dx.common.css" />
<link rel="stylesheet" type="text/css" href="https://cdn3.devexpress.com/jslib/22.1.4/css/dx.light.css" />
<script src="https://unpkg.com/core-js@2.4.1/client/shim.min.js"></script>
<script src="https://unpkg.com/zone.js@0.11.4/dist/zone.js"></script>
<script src="https://unpkg.com/reflect-metadata@0.1.3/Reflect.js"></script>
<script src="https://unpkg.com/systemjs@0.21.3/dist/system.js"></script>
<script src="config.js"></script>
<script>
System.import("app").catch(console.error.bind(console));
</script>
</head>
<body class="dx-viewport">
<div class="demo-container">
<demo-app>Loading...</demo-app>
</div>
</body>
</html>
using System.Collections.Generic;
using DevExtreme.MVC.Demos.Models.SignalR;
using Microsoft.AspNet.SignalR;
namespace DevExtreme.MVC.Demos.Hubs {
public class LiveUpdateSignalRHub : Hub {
private readonly StockTicker _stockTicker;
public LiveUpdateSignalRHub() {
_stockTicker = StockTicker.Instance;
}
public IEnumerable<Stock> GetAllStocks() {
return _stockTicker.GetAllStocks();
}
}
}
using System;
using System.Collections.Generic;
using System.Threading;
using DevExtreme.MVC.Demos.Hubs;
using Microsoft.AspNet.SignalR;
using Microsoft.AspNet.SignalR.Hubs;
namespace DevExtreme.MVC.Demos.Models.SignalR {
public class StockTicker {
public readonly static StockTicker Instance = new StockTicker(GlobalHost.ConnectionManager.GetHubContext<LiveUpdateSignalRHub>().Clients);
private readonly IEnumerable<Stock> _stocks;
private IHubConnectionContext<dynamic> Clients { get; set; }
private readonly TimeSpan _updateInterval = TimeSpan.FromMilliseconds(500);
private readonly Random _updateOrNotRandom = new Random();
private readonly Timer _timer;
private readonly object _updateStockPricesLock = new object();
static readonly Random random = new Random();
private StockTicker(IHubConnectionContext<dynamic> clients) {
Clients = clients;
_stocks = GenerateStocks();
_timer = new Timer(UpdateStockPrices, null, _updateInterval, _updateInterval);
}
public IEnumerable<Stock> GetAllStocks() {
return _stocks;
}
static IEnumerable<Stock> GenerateStocks() {
return new[] {
new Stock(37.95M) { Symbol = "MSFT", DayOpen=36.5M, LastUpdate = DateTime.Now },
new Stock(24.85M) { Symbol = "INTC", DayOpen=24.9M, LastUpdate = DateTime.Now },
new Stock(22.99M){ Symbol = "CSCO", DayOpen=22.7M, LastUpdate = DateTime.Now },
new Stock(30.71M){ Symbol = "SIRI", DayOpen=30.7M, LastUpdate = DateTime.Now },
new Stock(58.73M){ Symbol = "AAPL", DayOpen=54.9M, LastUpdate = DateTime.Now },
new Stock(110M){ Symbol = "HOKU", DayOpen=121.2M, LastUpdate = DateTime.Now },
new Stock(38.11M){ Symbol = "ORCL", DayOpen=37.9M, LastUpdate = DateTime.Now },
new Stock(17.61M) { Symbol = "AMAT", DayOpen=17.5M, LastUpdate = DateTime.Now },
new Stock(40.80M){ Symbol = "YHOO", DayOpen=39.9M, LastUpdate = DateTime.Now },
new Stock(31.85M){ Symbol = "LVLT", DayOpen=32.9M, LastUpdate = DateTime.Now },
new Stock(20.63M){ Symbol = "DELL", DayOpen=17.9M, LastUpdate = DateTime.Now },
new Stock(63.70M) { Symbol = "GOOG", DayOpen=55.9M, LastUpdate = DateTime.Now }
};
}
private void UpdateStockPrices(object state) {
lock(_updateStockPricesLock) {
foreach(var stock in _stocks) {
if(TryUpdateStockPrice(stock)) {
BroadcastStockPrice(stock);
}
}
}
}
private bool TryUpdateStockPrice(Stock stock) {
var r = _updateOrNotRandom.NextDouble();
if(r > .1) {
return false;
}
stock.Update();
return true;
}
private void BroadcastStockPrice(Stock stock) {
Clients.All.updateStockPrice(stock);
}
}
}
using System;
namespace DevExtreme.MVC.Demos.Models.SignalR {
public class Stock {
readonly decimal _initPrice;
public Stock(decimal price) {
Price = price;
DayMax = price;
DayMin = price;
_initPrice = Price;
}
public string Symbol { get; set; }
public decimal Price { get; set; }
public decimal DayMax { get; set; }
public decimal DayMin { get; set; }
public decimal DayOpen { get; set; }
public DateTime LastUpdate { get; set; }
public decimal Change {
get {
return Price - DayOpen;
}
}
public double PercentChange {
get {
return (double)Math.Round(Change * 100 / DayOpen, 2);
}
}
public void Update() {
var isNewDay = LastUpdate.Day != DateTime.Now.Day;
var change = GenerateChange();
var newPrice = _initPrice + _initPrice * change;
Price = newPrice;
LastUpdate = DateTime.Now;
if(Price > DayMax || isNewDay)
DayMax = Price;
if(Price < DayMin || isNewDay)
DayMin = Price;
}
static Random random = new Random();
decimal GenerateChange() {
return (decimal)random.Next(-200, 200) / 10000;
}
}
}