JHipster技术栈定制 - JHipster Registry消息总线配置
程序员文章站
2023-12-28 19:45:10
本文说明了如何定制化JHipster-Registry,增加消息总线功能。 ......
本文说明了如何定制化jhipster-registry,增加消息总线功能。
实现的效果就是修改配置中心的文件后,通过消息队列主动推送给微服务而无需重启微服务,实现配置内容热加载。
1 整体规划
1.1 拓扑架构
1.2 基础设置
编号 | ip | 主机名 |
---|---|---|
b | 10.70.24.135 | node02 |
c | 10.70.24.136 | node03 |
d | 10.70.24.85 | node04 |
e | 10.70.24.95 | node05 |
1.3 相关组件
组件名 | 说明 | 版本 |
---|---|---|
jhipster registry | 基于eureka和spring cloud config的基础服务。 | v4.0.0 |
spring cloud bus | 消息总线组件,通过maven依赖引入。 | 1.3.1 |
rabbitmq | 消息中间件,已部署在预研环境中。 | 3 |
myclient | 一个客户端服务,用于测试消息总线效果。 | 1.0 |
gitlab配置库 | jhipster-registry引用的配置中心。所有服务的配置文件所在地。 |
2 jhipster registry定制
2.1 下载源码
github上下载jhipster-jhipster源码。https://github.com/jhipster/jhipster-registry/releases
2.2 提交到gitlab
保存到本地gitlab源码库
2.3 配置文件定制
pom.xml
<dependency> <groupid>org.springframework.cloud</groupid> <artifactid>spring-cloud-starter-bus-amqp</artifactid> </dependency> <dependency> <groupid>org.springframework.boot</groupid> <artifactid>spring-boot-starter-actuator</artifactid> </dependency>
application.yml
management: security: enabled: false context-path: /management # 消息总线的url,这个前缀要加在 /bus/refresh 前面
application-prod.conf
spring: rabbitmq: host: rmqha_proxy port: 56729 username: guest password: guest publisher-confirms: true # 生产者消息确认 addresses: rmqha_proxy # 客户端访问server地址, 作为发送者,配置和host一致
2.4 项目构建
在安装了jdk,maven, yarn,nodejs的centos7服务器上执行命令
yarn && yarn install #前端资源配置生成 mvn -pprod clean package dockerfile:build #项目构建并打包成docker镜像,版本号为3.0
2.5 服务启动
docker service create --name base-registry --replicas 1 --network mycloud_base-overlay --constraint node.labels.mycloud.node.type==worker --constraint node.labels.mycloud.node.env==dev --env spring_profiles_active=prod,git --env jhipster_security_authentication_jwt_secret=gdd904a2dffb3eaf28a318b49e0ab986cc51012k --publish 8761:8761 dtr.devops.mycloud.com/common/jhipster-registry:3.0
可通过如下url访问http://<ip>:8761
3 客户端服务定制
3.1 创建项目
通过jhipster生成一个微服务,名为my-client。
3.2 提交到gitlab
保存到gitlab库git@gitlab.yourcompany.com:root-cloud/mycloud-monitor.git
3.3 配置文件定制
pom.xml
<dependency> <groupid>org.springframework.boot</groupid> <artifactid>spring-boot-starter-web</artifactid> </dependency> <dependency> <groupid>org.springframework.cloud</groupid> <artifactid>spring-cloud-starter-eureka</artifactid> </dependency> <dependency> <groupid>org.springframework.cloud</groupid> <artifactid>spring-cloud-starter-bus-amqp</artifactid> </dependency> <dependency> <groupid>org.springframework.boot</groupid> <artifactid>spring-boot-starter-actuator</artifactid> </dependency>
application-prod.yml
eureka: instance: prefer-ip-address: true client: service-url: # 指向eureka服务器 defaultzone: http://admin:${jhipster.registry.password}@base-registry:8761/eureka/ spring: rabbitmq: host: rmqha_proxy port: 56729 username: guest password: guest publisher-confirms: true # 生产者消息确认 addresses: rmqha_proxy # 客户端访问server地址, 作为发送者,配置和host一致
bootstrap-prod.yml
spring: cloud: config: fail-fast: true retry: initial-interval: 1000 max-interval: 2000 max-attempts: 100 uri: http://admin:${jhipster.registry.password}@base-registry:8761/config # 指向配置服务器 # name of the config server's property source (file.yml) that we want to use name: mq-client profile: rd # 注意这里是rd分支,springcloud-config.git上的rd分支 label: master # toggle to switch to a different version of the configuration as stored in git jhipster: registry: password: admin
myclientapp.java
@(jhipster)refreshscope # 加上这个注解 public class myclientapp { ...... }
3.4 添加测试代码
application-prod.yml
application: domain: http://yourcompany.com/2017 # 增加一个配置项
applicationproperties
@configurationproperties(prefix = "application", ignoreunknownfields = false) public class applicationproperties { private string domain = "http://default"; public string getdomain() { return domain; } public void setdomain(string domain) { this.domain = domain; } }
testresource.java
@restcontroller @requestmapping("/management") public class testresource { private final applicationproperties appproperties; @getmapping("/mq/property") @timed public responseentity<string> getproperty() { return responseutil.wrapornotfound(optional.ofnullable(appproperties.getdomain())); } }
3.5 项目构建
在安装了jdk,maven, yarn,nodejs的centos7服务器上执行命令
$ mvn -pprod clean package dockerfile:build #项目构建并打包成docker image
3.6 服务启动
docker service create --name mq-client-mysql --replicas 1 --network name=mycloud_base-overlay,alias=mq-client-mysql --constraint node.labels.mycloud.node.type==worker --constraint node.labels.mycloud.node.env==data --env mysql_root_password=my-secret-pw --publish 32781:3306 dtr.devops.mycloud.com/common/mysql:5 docker service create --name my-client-app --replicas 1 --network mycloud_base-overlay --constraint node.labels.mycloud.node.type==worker --constraint node.labels.mycloud.node.env==dev --env spring_profiles_active=prod,swagger --publish 18081:8081 dtr.devops.mycloud.com/yourcompany/my-client:1.0
可通过如下url访问http://<ip>:18081
4 测试效果
4.1 第1次查询配置项
http://<ip>:18081/management/mq/property
http://yourcompany.com/2017 # 返回值
4.2 修改配置项
application: domain: http://yourcompany.com/2018 # 把2017改成了2018
4.3 第2次查询配置项
http://<ip>:18081/management/mq/property
http://yourcompany.com/2017 # 返回值没有改变
4.4 通知消息总线
$ curl -x post http://<ip>:8761/management/bus/refresh
4.5 第3次查询配置项
http://<ip>:<port>/management/mq/property
http://yourcompany.com/2018 # 返回值已经更新为2018