SpringCloud Bus组件如何使用
SpringCloud Bus组件如何使用
本文小编为大家详细介绍“SpringCloudBus组件如何使用”，内容详细，步骤清晰，细节处理妥当，希望这篇“SpringCloudBus组件如何使用”文章能帮助大家解决疑惑，下面跟着小编的思路慢慢深入，一起来学习新知识吧。
什么是Bus
0.解释
https://spring.io/projects/spring-cloud-bus
springcloudbus使用轻量级消息代理将分布式系统的节点连接起来。然后，可以使用它来广播状态更改（例如配置更改）或其他管理指令。AMQP和Kafka broker实现包含在项目中。或者，在类路径上找到的任何springcloudstream绑定器都可以作为传输使用。
通俗定义: bus称之为springcloud中消息总线,主要用来在微服务系统中实现远端配置更新时通过广播形式通知所有客户端刷新配置信息,避免手动重启服务的工作
实现配置刷新原理
搭建RabbitMQ服务
0.下载rabbitmq安装包 [可以直接使用docker安装更方便] 官方安装包下载:https://www.rabbitmq.com/install-rpm.html#downloads
[注意:][这里安装包只能用于centos7.x系统]
1.将rabbitmq安装包上传到linux系统中
erlang-22.0.7-1.el7.x86_64.rpmrabbitmq-server-3.7.18-1.el7.noarch.rpm
2.安装Erlang依赖包
rpm-ivherlang-22.0.7-1.el7.x86_64.rpm
3.安装RabbitMQ安装包(需要联网)
yuminstall-yrabbitmq-server-3.7.18-1.el7.noarch.rpm注意:默认安装完成后配置文件模板在:/usr/share/doc/rabbitmq-server-3.7.18/rabbitmq.config.example目录中,需要将配置文件复制到/etc/rabbitmq/目录中,并修改名称为rabbitmq.config
4.复制配置文件
cp/usr/share/doc/rabbitmq-server-3.7.18/rabbitmq.config.example/etc/rabbitmq/rabbitmq.config
5.查看配置文件位置
ls/etc/rabbitmq/rabbitmq.config
6.修改配置文件(参见下图:)
vim/etc/rabbitmq/rabbitmq.config
将上图中配置文件中红色部分去掉%%,以及最后的,逗号 修改为下图:
7.执行如下命令,启动rabbitmq中的插件管理
rabbitmq-pluginsenablerabbitmq_management出现如下说明:Enablingpluginsonnoderabbit@localhost:rabbitmq_managementThefollowingpluginshavebeenconfigured:rabbitmq_managementrabbitmq_management_agentrabbitmq_web_dispatchApplyingpluginconfigurationtorabbit@localhost...Thefollowingpluginshavebeenenabled:rabbitmq_managementrabbitmq_management_agentrabbitmq_web_dispatchset3plugins.Offlinechange;changeswilltakeeffectatbrokerrestart.
8.启动RabbitMQ的服务
systemctlstartrabbitmq-serversystemctlrestartrabbitmq-serversystemctlstoprabbitmq-server
9.查看服务状态(见下图:)
systemctlstatusrabbitmq-server
● rabbitmq-server.service - RabbitMQ broker
Loaded: loaded (/usr/lib/systemd/system/rabbitmq-server.service; disabled; vendor preset: disabled)
Active: active (running) since 三 2019-09-25 22:26:35 CST; 7s ago
Main PID: 2904 (beam.smp)
Status: “Initialized”
CGroup: /system.slice/rabbitmq-server.service
├─2904 /usr/lib64/erlang/erts-10.4.4/bin/beam.smp -W w -A 64 -MBas ageffcbf -MHas ageffcbf -
MBlmbcs…
├─3220 erl_child_setup 32768
├─3243 inet_gethost 4
└─3244 inet_gethost 4
…
10.关闭防火墙服务
systemctldisablefirewalldRemovedsymlink/etc/systemd/system/multi-user.target.wants/firewalld.service.Removedsymlink/etc/systemd/system/dbus-org.fedoraproject.FirewallD1.service.systemctlstopfirewalld
11.访问web管理界面
http://10.15.0.8:15672/
12.登录管理界面
username:guestpassword:guest
13.MQ服务搭建成功
实现自动配置刷新
1.在所有项目中引入bus依赖
<!--引入bus依赖--><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-bus-amqp</artifactId></dependency>
2.配置统一配置中心连接到mq
spring.rabbitmq.host=localhost#连接主机spring.rabbitmq.port=5672#连接mq端口spring.rabbitmq.username=user#连接mq用户名spring.rabbitmq.password=password#连接mq密码
3.远端配置中加入连接mq配置
4.启动统一配置中心服务 正常启动
5.启动客户端服务 加入bus组件之后客户端启动报错原因springcloud中默认链接不到远程服务器不会报错,但是在使用bus消息总线时必须开启连接远程服务失败报错
spring.cloud.config.fail-fast=true
6.修改远程配置后在配置中心服务通过执行post接口刷新配置 curl -X POST http://localhost:7878/actuator/bus-refresh
7.通过上述配置就实现了配置统一刷新
指定服务刷新配置
1.说明
默认情况下使用curl -X POST http://localhost:7878/actuator/bus-refresh这种方式刷新配置是全部广播形式,也就是所有的微服务都能接收到刷新配置通知,但有时我们修改的仅仅是某个服务的配置,这个时候对于其他服务的通知是多余的,因此就需要指定服务进行通知
2.指定服务刷新配置实现
指定端口刷新某个具体服务: curl -X POST http://localhost:7878/actuator/bus-refresh/configclient:9090
指定服务id刷新服务集群节点: curl -X POST http://localhost:7878/actuator/bus-refresh/configclient
[注意:][configclient代表刷新服务的唯一标识]
集成webhook实现自动刷新
1.配置webhooks
添加webhooks
在webhooks中添加刷新配置接口
内网穿透可以使用natapp进行穿透，本地一个穿透免费穿透，https://natapp.cn/ 步骤非常简单。然后将穿透的地址放入到所需地址栏即可。
2.解决400错误问题
在配置中心服务端加入过滤器进行解决(springcloud中一个坑)
@ComponentpublicclassUrlFilterimplementsFilter{@Overridepublicvoidinit(FilterConfigfilterConfig)throwsServletException{}publicvoiddoFilter(ServletRequestrequest,ServletResponseresponse,FilterChainchain)throwsIOException,ServletException{HttpServletRequesthttpServletRequest=(HttpServletRequest)request;HttpServletResponsehttpServletResponse=(HttpServletResponse)response;Stringurl=newString(httpServletRequest.getRequestURI());//只过滤/actuator/bus-refresh请求if(!url.endsWith("/bus-refresh")){chain.doFilter(request,response);return;}//获取原始的bodyStringbody=readAsChars(httpServletRequest);System.out.println("originalbody:"+body);//使用HttpServletRequest包装原始请求达到修改post请求中body内容的目的CustometRequestWrapperrequestWrapper=newCustometRequestWrapper(httpServletRequest);chain.doFilter(requestWrapper,response);publicvoiddestroy(){privateclassCustometRequestWrapperextendsHttpServletRequestWrapper{publicCustometRequestWrapper(HttpServletRequestrequest){super(request);@OverridepublicServletInputStreamgetInputStream()throwsIOException{byte[]bytes=newbyte[0];ByteArrayInputStreambyteArrayInputStream=newByteArrayInputStream(bytes);returnnewServletInputStream(){@OverridepublicbooleanisFinished(){returnbyteArrayInputStream.read()==-1?true:false;}publicbooleanisReady(){returnfalse;publicvoidsetReadListener(ReadListenerreadListener){publicintread()throwsIOException{returnbyteArrayInputStream.read();};publicstaticStringreadAsChars(HttpServletRequestrequest){BufferedReaderbr=null;StringBuildersb=newStringBuilder("");try{br=request.getReader();Stringstr;while((str=br.readLine())!=null){sb.append(str);}br.close();catch(IOExceptione)e.printStackTrace();finallyif(null!=br)try{br.close();catch(IOExceptione)e.printStackTrace();returnsb.toString();}
读到这里，这篇“SpringCloudBus组件如何使用”文章已经介绍完毕，想要掌握这篇文章的知识点还需要大家自己动手实践使用过才能领会，如果想了解更多相关内容的文章，欢迎关注恰卡编程网行业资讯频道。
