世豪个人博客

全部文章

最新文章

Java 打包spring boot项目到docker

打包项目成jar文件新建文件dockerfile# Docker image for springboot file run# VERSION 0.0.1# Author: eangulee# 基础镜像使用javaFROM java:8# 作者MAINTAINER lsh# VOLUME 指定了临时文件目录为/tmp。# 其效果是在主机 /var/lib/docker 目录下创建了一个临时文件，并链接到容器的/tmpVOLUME /tmp # 将jar包添加到容器中并更名为app.jarADD blog-1.0.0.jar app.jar# 运行jar包RUN bash -c 'touch /app.jar'ENTRYPOINT ["java","-Djava.security.egd=file:/dev/./urandom","-jar","/app.jar"]把这两个文件放在同一个文件夹下，然后运行命令，打包成一个镜像docker build -t blog .执行docker images即可看到多了一个镜像然后启动该镜像docker run -d -p 8080:80 --name blog --restart=always blog打开防火墙，设置规则，即可访问该服务

2021-12-01 12:03:59 浏览（1,459）阅读原文>>
Java spring cloud sleuth

添加依赖 <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-sleuth</artifactId> </dependency>需要跟踪的链路日志级别可视化界面地址docker安装docker run -d -p 9411:9411 --restart=always openzipkin/zipkin 如何把这两者关联起来<dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-sleuth-zipkin</artifactId> </dependency>其实这个依赖包含了上面这两个添加配置:（spring下）

2021-06-09 23:01:43 浏览（1,508）阅读原文>>
Java spring cloud hystrix

添加依赖 <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-netflix-hystrix</artifactId> </dependency>启动类添加依赖服务降级方式一方式二超时时间设置熔断机制设置配置方式开启，必须要加上注解：@HystrixCommand(commandKey = "test")hystrix可视化工具<dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-netflix-hystrix-dashboard</artifactId> </dependency>访问端口

2021-06-08 22:48:46 浏览（704）阅读原文>>
Java spring cloud zuul

新建zuul应用注意:如果zuul不可选，需要降低一下spring boot版本添加eureka，跟config配置eureka: client: service-url: defaultZone: http://localhost:8761/eurekaspring: application: name: zuul cloud: config: discovery: enabled: true service-id: CONFIG_SERVER profile: dev在启动类添加配置使用其他端口访问:http://localhost:8081/test的接口使用zuul的端口访问（centos_blog是eureka上的应用名称，最好别用驼峰）相关配置屏蔽某些地址配置查看路由映射地址:http://localhost:9000/application/routes关闭过滤信息实现高可用，即把多个zuul应用部署到eureka上即可通过zuul对参数校验例子，请求必须带有token参数@Componentpublic class TokenFilter extends ZuulFilter { @Override public String filterType() { return PRE_TYPE; } @Override public int filterOrder() { //越小优先级越高 return PRE_DECORATION_FILTER_ORDER -1; } @Override public boolean shouldFilter() { return true; } @Override public Object run(){ RequestContext requestContext = RequestContext.getCurrentContext(); HttpServletRequest request = requestContext.getRequest(); String token = request.getParameter("token"); if (StringUtils.isBlank(token)) { requestContext.setSendZuulResponse(false); requestContext.setResponseStatusCode(HttpStatus.UNAUTHORIZED.value()); } return null; }}例子二，post请求返回，在head添加内容@Componentpublic class AddHeadFilter extends ZuulFilter { @Override public String filterType() { return POST_TYPE; } @Override public int filterOrder() { return SEND_RESPONSE_FILTER_ORDER - 1; } @Override public boolean shouldFilter() { return true; } @Override public Object run() { RequestContext requestContext = RequestContext.getCurrentContext(); HttpServletResponse httpResponse = requestContext.getResponse(); httpResponse.setHeader("abv", "asd"); return null; }}例子三:限流，用获取令牌的方式@Componentpublic class RateFilter extends ZuulFilter { //每秒放100个令牌 private static final RateLimiter RATE_LIMITER = RateLimiter.create(100); @Override public String filterType() { //优先级最高 return PRE_TYPE; } @Override public int filterOrder() { return SERVLET_DETECTION_FILTER_ORDER - 1; } @Override public boolean shouldFilter() { return true; } @Override public Object run() throws ZuulException { //如果没有令牌 if(!RATE_LIMITER.tryAcquire()) { throw new RuntimeException("没有获取令牌"); } return null; }}统一去除所有敏感头过滤例子四:权限控制@Componentpublic class AuthFilter extends ZuulFilter { @Override public String filterType() { return PRE_TYPE; } @Override public int filterOrder() { //越小优先级越高 return PRE_DECORATION_FILTER_ORDER -1; } @Override public boolean shouldFilter() { //是否进行拦截 RequestContext requestContext = RequestContext.getCurrentContext(); HttpServletRequest request = requestContext.getRequest(); //可改成数据库配置，从redis读取 if("/login".equals(request.getRequestURI())) { return false; } return true; } @Override public Object run(){ //拦截处理 //可不同角色新建不同的filter RequestContext requestContext = RequestContext.getCurrentContext(); HttpServletRequest request = requestContext.getRequest(); if (StringUtils.isNotBlank(request.getHeader("token"))) { throw new RuntimeException("拦截"); } return null; }}例子5，跨域@Configurationpublic class CorsConfig { @Bean public CorsFilter corsFilter() { final UrlBasedCorsConfigurationSource source = new UrlBasedCorsConfigurationSource(); final CorsConfiguration config = new CorsConfiguration(); config.setAllowCredentials(true); config.setAllowedOrigins(Collections.singletonList("*")); config.setAllowedHeaders(Collections.singletonList("*")); config.setAllowedMethods(Collections.singletonList("*")); config.setMaxAge(300L); source.registerCorsConfiguration("/**", config); return new CorsFilter(source); }}

2021-06-06 21:34:19 浏览（669）阅读原文>>
Java spring cloud stream

添加依赖 <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-stream-rabbit</artifactId> </dependency>新建接口public interface StreamClient { String INPUT = "input"; String OUTPUT = "output"; @Input(StreamClient.INPUT) SubscribableChannel input(); @Output(StreamClient.OUTPUT) MessageChannel output();}接收类@Component@EnableBinding(StreamClient.class)@Slf4jpublic class StreamReceiver { @StreamListener(StreamClient.INPUT) public void process(Object message) { log.info("processInput:{}", message); } @StreamListener(StreamClient.OUTPUT) public void processOutput(Object message) { log.info("processOutput:{}", message); }}controller@RestControllerpublic class SendMessageController { @Autowired private StreamClient streamClient; @GetMapping("sendMessage") public void sendMessage() { String message = "now : " + "asdasd"; streamClient.output().send( MessageBuilder.withPayload(message).build()); }}为了防止被应用的多个实例消费，可进行分组，在配置添加返回处理成功，通过mq发送

2021-06-06 17:47:36 浏览（689）阅读原文>>
Java rabbitmq的基本使用

上一章我们使用了rabbitmq，这章讲一下它的基本使用在应用层添加依赖<dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-amqp</artifactId> </dependency>添加配置，可放在config远程仓库监听消息可使用带key的形式需在rabbitmq新增相应的队列发送消息代码发送方由key匹配相应的队列

2021-06-06 11:50:39 浏览（668）阅读原文>>
Java spring cloud bus的使用

在上一节的spring cloud config中会存在一个问题，项目启动时候会读取远程配置，但是如果远程配置中心地址发生变更，本地的信息还是用以前的，这个时候就会需要spring cloud bus进行配置刷新在config-server和应用层添加配置<dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-bus-amqp</artifactId> </dependency>使用这个需要mq支持，这里我用的是rabbitmq，使用docker安装，这些docker安装我就不阐述了，安装完docker使用这条指令就行了docker run -d --hostname my-rabbitmq -p 5672:5672 -p 15672:15672 --restart=always rabbitmq:3.7.3-management安装结束后访问:http://localhost:15672/,输入账号密码:guest / guest在config-server添加配置，过滤屏蔽management: endpoints: web: exposure: include: "*"（高版本可能有问题，调整spring boot版本为2.2.5.RELEASE， spring cloud版本为:Hoxton.SR3 即可解决）使用post请求访问端口：http://localhost:8080/actuator/bus-refresh，触发刷新，可以在rabbitmq看到消息在使用配置的地方启动刷新打开gitee，可添加webhook，每次代码有变动都可以触发接口

2021-06-05 23:17:59 浏览（615）阅读原文>>
Java spring cloud config使用

config server应用创建一个新的项目，他首先必须是一个eureka client 在application类添加注解在gitee创建一个仓库config，新增一个文件test.yml,内容如下在项目配置文件添加配置启动访问地址，即可得到内容不知道大家有没有发现，文件后不加后缀根本无法访问其实他的读取格式是这个的/{name}-{profiles}.yml/{label}/{name}-{profiles}.yml其中意思是:name 服务名,profiles 环境,label分支（branch），不写默认master从远程拉的配置文件会缓存到本地，从日志就可以看出config client 应用 <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-config-client</artifactId> </dependency>在别的应用项目上添加config client依赖，并修改配置文件为了让项目启动先去拉去远程配置，才读取，而不是先读取配置，所以要把application.yml文件名修改成bootstrap.yml高可用其实跟eureka一样，同一个项目，多启动多个实例就行了需要注意的一点，去读取远程的配置，首先先去读eureka的内容，如果eureka发生变更，就会造成无法读取内容，所以推荐把eureka的配置，放到项目中如果多配置的话，会进行合并操作，再读取

2021-06-03 22:29:40 浏览（673）阅读原文>>
Java spring cloud feign的使用

新建一个client应用，引入依赖 <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-openfeign</artifactId> </dependency>在application类添加注解写一个接口@FeignClient(name = "centerBlog") name对应eureka的对应client实例名称，并对应起@GetMapping注解方法新建实现类在对应的client项目中，实现对应的方法运行项目即可查看相关内容

2021-06-01 23:20:25 浏览（603）阅读原文>>
Java spring cloud eureka高可用

idea创建eureka server应用 application类添加注解新建三个application.yml,在原配置文件上spring: profiles: active: ${active}另外三个配置如下，对应修改一下defaultZone，hostname，nameeureka: client: # 应用为注册中心，不注册自己 register-with-eureka: false # 注册中心职责是维护服务实例，不需要检索服务 fetch-registry: false service-url: defaultZone: http://localhost:8762/eureka,http://localhost:8763/eureka instance: hostname: localhost1spring: application: name: eureka-service1在idea上对这个eureka server应用复制成三个，并分别设置每个eureka server的启动参数这样就可以一份代码，启动三个eureka server应用了idea创建eureka client应用需要注意的是一定要添加web的依赖，不然会报错 <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-web</artifactId> </dependency>application类添加注解在配置文件添加配置, defaultZone是eureka server地址eureka: client: service-url: defaultZone: http://localhost:8761/eureka,http://localhost:8762/eureka,http://localhost:8763/eureka instance: hostname: eurekaClientspring: application: name: eureka-client启动即可在eureka server看到对应的client信息

2021-05-31 23:15:17 浏览（674）阅读原文>>

1 2 尾页