我正在学习并使用rails构建emberjs应用程序.
在这个应用程序中,我希望数据被推送而不是被轮询到客户端应用程序.
在这个应用程序中,我希望数据被推送而不是被轮询到客户端应用程序.
For.e.g.以下片段在http://awardwinningfjords.com/2011/12/27/emberjs-collections.html
// Setup a global namespace for our code.
Twitter = Em.Application.create({
// When everything is loaded.
ready: function() {
// Start polling Twitter
setInterval(function() {
Twitter.searchResults.refresh();
},2000);
// The default search is empty,let's find some cats.
Twitter.searchResults.set("query","cats");
// Call the superclass's `ready` method.
this._super();
}
});
它调查twitter API,但我的问题是如何使一个使用WebSocket连接更新其状态的EmberJS应用程序？
解决方法
您必须实现一个了解如何处理WebSockets的DS.Adapter.这是一个简单的例子：
var SOCKET = 'ws://localhost:9090/some-websocket';
var ID = 'uuid';
var FIND = 'find';
var FIND_MANY = 'findMany';
var FIND_QUERY = 'findQuery';
var FIND_ALL = 'findAll';
/**
* Implementation of WebSocket for DS.Store
*/
App.Store = DS.Store.extend({
revision: 4,adapter: DS.Adapter.create({
socket: undefined,requests: undefined,send: function(action,type,data,result) {
/* Specific to your web socket server side implementation */
var request = {
"uuid": generateUuid(),"action": action,"type": type.toString().substr(1),"data": data
};
this.socket.send(JSON.stringify(request));
/* So I have access to the original request upon a response from the server */
this.get('requests')[request.uuid] = request;
return request;
},find: function (store,id) {
this.send(FIND,id);
},findMany: function (store,ids,query) {
this.send(FIND_MANY,ids);
},findQuery: function (store,query,modelArray) {
this.send(FIND_QUERY,modelArray).modelArray = modelArray;
},findAll: function (store,type) {
this.send(FIND_ALL,type);
},/* Also implement:
* createRecord & createRecords
* updateRecord & updateRecords
* deleteRecord & deleteRecords
* commit & rollback
*/
init: function () {
var context = this;
this.set('requests',{});
var ws = new WebSocket(SOCKET);
ws.onopen = function () {
};
ws.onmessage = function(event) {
var response = JSON.parse(event.data);
var request = context.get('requests')[response.uuid];
switch (request.action) {
case FIND:
App.store.load(type,response.data[0]);
break;
case FIND_MANY:
App.store.loadMany(type,response.data);
break;
case FIND_QUERY:
request.modelArray.load(response.data);
break;
case FIND_ALL:
App.store.loadMany(type,response.data);
break;
default:
throw('UnkNown Request: ' + request.action);
}
/* Cleanup */
context.get('requests')[response.uuid] = undefined;
};
ws.onclose = function () {
};
this.set('socket',ws);
}
});
});