53 lines
1.2 KiB
JavaScript
53 lines
1.2 KiB
JavaScript
const Haz = require('hazelcast-client');
|
|
// const config = new Haz.Config.ClientConfig();
|
|
let globalClient = null;
|
|
|
|
// config.listeners.addLifecycleListener(function (state) {
|
|
// console.log('Lifecycle Event >>> ' + state);
|
|
// if(state === 'shutdown'){
|
|
// console.log('WE ARE DEAD!');
|
|
// }
|
|
// });
|
|
|
|
const cfg = {
|
|
network: {
|
|
clusterMembers: [
|
|
'127.0.0.1:5701',
|
|
]
|
|
},
|
|
groupConfig: {
|
|
name: 'ona',
|
|
password: '123456'
|
|
},
|
|
lifecycleListeners: [
|
|
(state) => {
|
|
console.log(`Hazelcast lifecycle Event >>> ${state}`);
|
|
}],
|
|
};
|
|
|
|
const config = new Haz.Config.ClientConfig(cfg);
|
|
|
|
Haz.Client.newHazelcastClient(config).then((client) => {
|
|
console.log('Success!', client);
|
|
globalClient = client;
|
|
console.log(globalClient.getLocalEndpoint());
|
|
|
|
|
|
})
|
|
.catch((err) => {
|
|
console.log(err)
|
|
});
|
|
|
|
|
|
setInterval(async () => {
|
|
try{
|
|
console.log('Client >>>>>>');
|
|
|
|
if(globalClient){
|
|
const map = await globalClient.getMap('qqz');
|
|
console.log('value: ', await map.put('q', Date.now()));
|
|
}
|
|
}catch(e) {
|
|
console.log('>>>>>>>>>>>>>>>>>', e)
|
|
}
|
|
}, 5000); |