初始化
npm init
Eureka注册中心默认是30s检测一下服务是否可用。
https://github.com/arthas001/eureka-node-client
安装eureka-node-client
npm install eureka-node-client --save
注册服务
register.js
let Eureka = require('eureka-node-client');
let hostname = "127.0.0.1";
let port = 3000;
let eureka_address = process.env.EUREKA_ADDRESS || '110.110.110.110';
let eureka_port = process.env.EUREKA_PORT || '8302';
let eureka_username = process.env.EUREKA_USERNAME || 'admin';
let eureka_password = process.env.EUREKA_PWD || 'admin';
const eureka_client = new Eureka({
eureka: {
host: `${eureka_username}:${eureka_password}@${eureka_address}`,
port: eureka_port,
servicePath: "/eureka/apps/"
},
instance: {
app: "sliverecord",
port: {'$': port, '@enabled': 'true'},
homePageUrl: `http://${hostname}:${port}/`,
healthCheckUrl: `http://${hostname}:${port}/health`,
statusPageUrl: `http://${hostname}:${port}/health`,
metadata: {
zone: 'primary',
env: process.env.NODE_ENV,
version: "1.0"
}
}
});
/**
* 设置日志级别
*/
eureka_client.logger.level('debug');
//******************** 测试监听 ********************//
let updatedListener = function (apps) {
console.log("更新:" + JSON.stringify(apps));
}
eureka_client.onUpdated(updatedListener);
eureka_client.start(function (error) {
console.log(error || '启动成功!');
});
其中
注册地址简写,关闭时注销注册
let Eureka = require('eureka-node-client');
let hostname = "127.0.0.1";
let port = 3000;
const eureka_client = new Eureka({
eureka: {
"serviceUrls": {
"default": [
"http://admin:admin@49.4.26.249:8302/eureka/apps/",
]
}
},
instance: {
app: "sliverecord",
port: {'$': port, '@enabled': 'true'},
homePageUrl: `http://${hostname}:${port}/`,
healthCheckUrl: `http://${hostname}:${port}/health`,
statusPageUrl: `http://${hostname}:${port}/health`,
}
});
/**
* 设置日志级别
*/
eureka_client.logger.level('debug');
//******************** 测试监听 ********************//
let updatedListener = function (apps) {
console.log("更新:" + JSON.stringify(apps));
}
eureka_client.onUpdated(updatedListener);
eureka_client.start(function (error) {
console.log(error || '启动成功!');
});
process.on('SIGINT', function() {
eureka_client.stop();
setTimeout(()=>{process.exit();},300)
});
注意
程序退出要延迟执行,否则取消注册不成功。
安装express
npm install express --save
使用express挂起服务
const express = require('express');
const app = express();
app.get('/health', (req, res) => {
res.json({
status: 'UP'
});
});
app.get('/', (req, res, next) => {
res.json({code: 0, msg: "success!"});
});
app.listen(3000);
测试Eureka服务
启动服务的时候启动注册服务
const express = require('express');
const app = express();
app.get('/health', (req, res) => {
res.json({
status: 'UP'
});
});
app.get('/', (req, res, next) => {
res.json({code: 0, msg: "success!"});
});
app.listen(3000);
const { spawn } = require('child_process');
const grep = spawn('node', ['register.js']);
grep.on('close', (code, signal) => {
console.log(`子进程终止`);
process.exit();
});
在收到SIGINT
信号后,会先结束子进程,所以我们可以监听子进程的关闭事件再关闭主进程
grep.on('close', (code, signal) => {
console.log(`子进程终止`);
process.exit();
});