springboot 注册服务注册中心(zk)的两种方式
在使用springboot进行开发的过程中,我们经常需要处理这样的场景:在服务启动的时候,需要向服务注册中心(例如zk)注册服务状态,以便当服务状态改变的时候,可以故障摘除和负载均衡。
我遇到过两种注册的途径:
1、在Spring的webapplication启动完成后,直接进行注册;
2、在servlet容器启动完成后,通过listener进行注册。
本文通过一个demo讲述一下这两种注册方式,使用的是传统的向zk注册的方案。
1、Spring webapplication启动完成后注册
先上代码看一下
@SpringBootApplication
public class WebApplication {
private static final Logger logger = LoggerFactory.getLogger(WebApplication.class);
private static volatile boolean IS_REGISTRY = false;
public static void main(String[] args) {
ApplicationContext context = run(WebApplication.class, args);
if (IS_REGISTRY) {
logger.info("注册2: WebApplication启动完成后");
ZkClient zkClient = context.getBean(ZkClient.class);
zkClient.register();
IS_REGISTRY = true;
logger.info("注册2: 注册成功");
}
}
}
这里,我们在WebApplication中,获取zkClient,并进行注册。
这里需要说明一点,我们这里通过ApplicationContext来获取zkClient的bean,原因是在webApplication的初始化过程中你不能用Autowired的方式注入Bean,因为在webApplication启动过程中才会读所有的configuration并将bean初始化完成,在没有完成初始化之前,你不能注入bean。
关于注册的详细代码这里不展开了。
2、在servlet容器初始化完成后,通过listener的方式进行注册
照样先上代码
@WebListener
public class RegisterListener implements ServletContextListener {
protected final Logger logger = LoggerFactory.getLogger(this.getClass());
private static volatile boolean IS_REGISTRY = false;
@Autowired
private ZkClient zkClient;
@Override
public void contextInitialized(ServletContextEvent servletContextEvent) {
try {
if (!IS_REGISTRY) {
logger.info("注册1: Servelet容器启动成功后");
zkClient.register();
logger.info("注册1: 注册成功");
}
IS_REGISTRY = true;
} catch (Exception e) {
IS_REGISTRY = false;
logger.info("注册1: 注册失败");
}
}
@Override
public void contextDestroyed(ServletContextEvent servletContextEvent) {
if (IS_REGISTRY) {
zkClient.stop();
}
}
}
你需要先写一个listener,这个listener实现ServletContextListener接口,并且用@WebListener进行注解,这是springboot注解式的listener书写方式。
在servlet容器启动成功之后,会调用这个监听器的contextInitialized方法,servlet容器如果一旦销毁,不能提供服务了,会调用监听器的contextDestroyed方法。换句话说,这个监听器在监听servlet容器的状态。
然后你只需要在application主类中打开listener配置就好。
@ServletComponentScan
@SpringBootApplication
public class WebApplication {
}
3、这两种方式的比较
对于一个对外提供http协议的web服务,在语义上servlet容器的注册会显得清晰一些,但是如果你的spring容器启动时间过长的话,可能出现servlet初始化完成,并且已经注册,但是服务不能对外提供访问的gap time,所以我一般还是使用第一种方式进行注册。
这种场景是这样的
可以看到,当servlet注册成功之后,其实webapplication还没有启动完成,这个时候服务是不能正常提供访问的。
在zk上可以看到,两次注册都已经成功了。
- 我的学习、归纳方法(以学习 Maven 为例)
- JDBC面试题都在这里
- 018 final 关键字的用途
- 04-01.总结switch,for,while,do。while跳转语句
- JDBC【介绍JDBC、使用JDBC连接数据库、简单的工具类】
- 019 单例模式的5种写法
- 图书管理系统【部署开发环境、解决分类、图书、前台页面模块】
- 图书管理系统【用户、购买、订单模块、添加权限】
- 04-02.总结switch,for,while,do。while跳转语句
- 图书管理系统【总结】
- JDBC【PreparedStatment、批处理、处理二进制、自动主键、调用存储过程、函数】
- JDBC【事务、元数据、改造JDBC工具类】
- JDBC【数据库连接池、DbUtils框架、分页】
- HTTP常见面试题
- java教程
- Java快速入门
- Java 开发环境配置
- Java基本语法
- Java 对象和类
- Java 基本数据类型
- Java 变量类型
- Java 修饰符
- Java 运算符
- Java 循环结构
- Java 分支结构
- Java Number类
- Java Character类
- Java String类
- Java StringBuffer和StringBuilder类
- Java 数组
- Java 日期时间
- Java 正则表达式
- Java 方法
- Java 流(Stream)、文件(File)和IO
- Java 异常处理
- Java 继承
- Java 重写(Override)与重载(Overload)
- Java 多态
- Java 抽象类
- Java 封装
- Java 接口
- Java 包(package)
- Java 数据结构
- Java 集合框架
- Java 泛型
- Java 序列化
- Java 网络编程
- Java 发送邮件
- Java 多线程编程
- Java Applet基础
- Java 文档注释
- MySQL死锁产生原因和解决方法
- 文件操作与文件夹操作
- 使用文件字节输入流FileInputStream读取文件
- 二进制与十进制与十六进制介绍+转换+图解
- Swagger 3.0 官方 starter 诞生了,其它的都可以扔了~
- 原码+反码+补码概述与示范
- HTTP客户端连接,选择HttpClient还是OkHttp?
- 数据类型(基本数据类型和引用数据类型)范围与字符转换,代码示例+个位十位百位相加面试题
- Scanner关键字的使用+代码介绍+注意事项
- 将一个txt文件,复制到另一个txt文件中(缓冲字节流(BufferedInputStream,BufferedOutputStream))
- java实现客户端服务端互发消息并接收
- 使用NIO实现非阻塞式(相对的)多人聊天室
- 三次握手与四次挥手+图解
- 单例模式-->饿汉式+懒汉式
- 非常有必要了解的Springboot启动扩展点