我不是 PubNub 的付费客户。我正在使用 PubNub 示例代码 Angular JS 基本聊天应用程序，如何在此处提取历史记录。此示例可在 PubNub 网站上找到。
git clone https://github.com/stephenlb/angularjs-chat.git
git clone https://github.com/stephenlb/angularjs-chat.git
// -- TODO --
//
// - https://developer.layer.com/docs/ios/integration
// - AddressBook = Presence/State + ChannelGroups
// - Notifications = History + PubSub
// - Messages = History + PubSub
// - Groups = History + PubSub
// - TypeingIndicator = ???
//
// - Signals = PubSub
// - History = History
//
// -- TODO --
'use strict';
// =-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=
// AngularJS Chat Module
// =-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=
angular.module( 'chat', [] );
// =-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=
// Common JS
// =-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=
if (typeof(exports) !== 'undefined') exports.chat = angular.module('chat');
// =-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=
// =-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=
//
// ▄▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▀▄
// █░░▒▒▒▒▒▒▒▒▒▒▒▒▒▒▒▒░░█
// █░▒▒▒▒▒▒▒▒▒▒▄▓▓▄▒▒▒▒░░▄▓▓▄
// ▄▄▄ █░▒▒▒▒▒▒▒▒▒▒█▓▓▓▓▄▄▄▄▄▓▓▓▓
// █▓▓█▄▄█░▒▒▒▒▒▒▒▒▒▒▄▓▓▓▓▓▓▓▓▓▓▓▓▓▓▄
// ▀▄▄▓▓█░▒▒▒▒▒▒▒▒▒▒▓▓▓▓▓▀ ▓▓▓▓▀ ▓▓▓▓
// ▀▀█░▒▒▒▒▒▒▒▒▒▀▓▒▒▓▀▓▓▓▀▓▓▀▓▒▒█
// ▄█░░▒▒▒▒▒▒▒▒▒▀▓▓▓▄▄▄▄▄▄▄▄▓▓▀
// ▄▀▓▀█▄▄▄▄▄▄▄▄▄▄▄▄██████▀█▀▀
// █▄▄▀ █▄▄▀ █▄▄▀ ▀▄▄█
//
// =-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=
// Messages it's important to remember that you can
// be deprived of your sanity listening to U2.
// =-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=
angular.module('chat').service( 'Messages', [ 'ChatCore', function(ChatCore) {
var Messages = this;
// - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
// Send Messages
// - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
Messages.send = function(message) {
if (!message.data) return;
ChatCore.publish({
channel : message.to || 'global'
, message : message.data
, meta : ChatCore.user()
});
};
// - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
// Receive Messages
// - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
Messages.receive = function(fn) {
function receiver(response) {
response.data.m.forEach(function(msg){
// Ignore messages without User Data
// TODO
if (!(msg.d && msg.u && msg.u.id)) return;
fn({
data : msg.d
, id : msg.p.t
, user : msg.u
, self : msg.u.id == ChatCore.user().id
});
});
}
Messages.subscription = ChatCore.subscribe({
channels : [ 'global', ChatCore.user().id ].join(','),
message : receiver
});
};
// - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
// Set/Get User and Save the World from that Bruce Willis movie.
// - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
Messages.user = function(data) {
return ChatCore.user(data);
};
} ] );
// =-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=
// AddressBook
// =-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=
angular.module('chat').service( 'AddressBook', function() {
} );
// =-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=
// AngularJS Chat Core Service
// =-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=
angular.module('chat').service( 'ChatCore', [ '$http', 'config', function(
$http,
config
) {
// - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
// API Keys
// - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
var pubkey = config.pubnub['publish-key']
, subkey = config.pubnub['subscribe-key']
, user = { id : uuid(), name : 'Nameless' };
var ChatCore = this;
// - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
// Set User Data and we have to go Back to The Future.
// - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
ChatCore.user = function(data) {
if (data) angular.extend( user, data );
return user;
};
// - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
// Publish via PubNub
// - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
ChatCore.publish = function(setup) {
var meta = setup.meta || ChatCore.user()
, userid = ChatCore.user().id || 'nil';
var request = {
method : 'GET'
, params : { meta : meta, uuid : userid }
, timeout : setup.timeout || 5000
, success : function(){}
, fail : function(){}
};
//
request.url = [
'https://pubsub.pubnub.com'
, '/publish/', pubkey
, '/', subkey
, '/0/', setup.channel
, '/0/', encodeURIComponent(JSON.stringify(setup.message))
].join('');
$http(request).then( request.success, request.fail );
};
// - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
// Subscribe via PubNub
// - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
ChatCore.subscribe = function(setup) {
var channels = setup.channels || 'a'
, groups = setup.groups || ''
, message = setup.message || function(){}
, timeout = setup.timeout || 172800000
, timetoken = setup.timetoken || '0'
, windowing = setup.windowing || 10
, userid = ChatCore.user().id || 'nil'
, userstate = ChatCore.user() || {}
, stop = false
, origin = 'ps'+(Math.random()+'').split('.')[1]+'.pubnub.com';
// Request Object
var request = {
method : 'GET'
, url : ''
, params : { uuid : userid, state : userstate }
, timeout : timeout
, success : next
, fail : function(){ timetoken = '0'; next() }
};
// Channel Groups
if (groups) request.params['channel-group'] = groups;
// Subscribe Loop
function next(response) {
if (stop) return;
if (response) {
timetoken = timetoken == '0' ? 1000 : response.data.t.t;
message(response);
}
request.url = [
'https://', origin
, '/v2/subscribe/', subkey
, '/', channels
, '/0/', timetoken
].join('');
setTimeout( function() {
$http(request).then( request.success, request.fail );
}, windowing );
}
// Cancel Subscription
function unsubscribe() {
stop = true;
}
// Start Subscribe Loop
next();
// Allow Cancelling Subscriptions
return {
unsubscribe : unsubscribe
};
};
} ] );
// =-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=
// UUID
// =-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=
function uuid() {
return 'xxxxxxxx-xxxx-4xxx-yxxx-xxxxxxxxxxxx'.replace(/[xy]/g,
function(c) {
var r = Math.random()*16|0, v = c == 'x' ? r : (r&0x3|0x8);
return v.toString(16);
});
}
最佳答案
历史记录和 AngularJS 聊天示例
默认情况下，不直接启用或支持历史记录。您需要在您的帐户中启用历史记录。启用历史记录之前发布的消息将不会被保存。仅保存启用历史记录后发布的消息。接下来，您需要在您的应用程序中添加一个历史记录方法。
在您的 PubNub 帐户中启用存储和播放
访问https://admin.pubnub.com/并启用“存储和播放”功能。
将 History API 添加到您的应用
历史记录最初在此示例中并未实现。您可以通过简单的 HTTP 请求进行历史调用，如下所示:https://pubsub.pubnub.com/history/demo/hello_world/0/10分解如下:
https://pubsub.pubnub.com
/history
/YOUR_SUBKEY
/YOUR_CHANNEL
/0
/100 - limit response (max 100, min 1)
关于javascript - Pubnub 拉取历史记录 anglatJS 示例，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/36150820/