微信公众号搜"智元新知"关注
微信扫一扫可直接关注哦!

SpringCloud学习记录一

springcloud eureka

Caused by: java.lang.ArrayStoreException: sun.reflect.annotation.TypeNotPresentExceptionProxy
	at sun.reflect.annotation.AnnotationParser.parseClassArray(AnnotationParser.java:724) ~[na:1.8.0_77]
	at sun.reflect.annotation.AnnotationParser.parseArray(AnnotationParser.java:531) ~[na:1.8.0_77]
	at sun.reflect.annotation.AnnotationParser.parseMemberValue(AnnotationParser.java:355) ~[na:1.8.0_77]
	at sun.reflect.annotation.AnnotationParser.parseAnnotation2(AnnotationParser.java:286) ~[na:1.8.0_77]
	at sun.reflect.annotation.AnnotationParser.parseAnnotations2(AnnotationParser.java:120) ~[na:1.8.0_77]
	at sun.reflect.annotation.AnnotationParser.parseAnnotations(AnnotationParser.java:72) ~[na:1.8.0_77]
	at java.lang.class.createAnnotationData(Class.java:3521) ~[na:1.8.0_77]
	at java.lang.class.annotationData(Class.java:3510) ~[na:1.8.0_77]
	at java.lang.class.getDeclaredAnnotations(Class.java:3477) ~[na:1.8.0_77]

是导入错误的依赖,应该是

  <dependency>
      <groupId>org.springframework.cloud</groupId>
      <artifactId>spring-cloud-starter-netflix-eureka-server</artifactId>
      <version>2.2.2.RELEASE</version>
</dependency>

springcloud zookeeper

启动类中

@EnablediscoveryClient // 该注解用户向使用consul或者zookeeper作为注册中心注册服务

问题1

Caused by: org.springframework.context.ApplicationContextException: Unable to start ServletWebServerApplicationContext due to missing ServletWebServerFactory bean.
	at org.springframework.boot.web.servlet.context.ServletWebServerApplicationContext.getWebServerFactory(ServletWebServerApplicationContext.java:203) ~[spring-boot-2.2.2.RELEASE.jar:2.2.2.RELEASE]
	at org.springframework.boot.web.servlet.context.ServletWebServerApplicationContext.createWebServer(ServletWebServerApplicationContext.java:179) ~[spring-boot-2.2.2.RELEASE.jar:2.2.2.RELEASE]
	at org.springframework.boot.web.servlet.context.ServletWebServerApplicationContext.onRefresh(ServletWebServerApplicationContext.java:153) ~[spring-boot-2.2.2.RELEASE.jar:2.2.2.RELEASE]
	... 13 common frames omitted

解决:看启动类中的名字是否无误

问题2

rg.apache.zookeeper.KeeperException$ConnectionLossException: KeeperErrorCode = ConnectionLoss for /services/payment8004/cccfa2da-c8d8-4b5c-bdb6-b8fbdfd7eb08
	at org.apache.zookeeper.KeeperException.create(KeeperException.java:99) ~[zookeeper-3.5.3-beta.jar:3.5.3-beta-8ce24f9e675cbefffb8f21a47e06b42864475a60]
	

版本不一致,去除spring-cloud-starter-zookeeper-discovery的3.5.3-beta的jar,新增LATEST版本zookeeper

Caused by: java.lang.IllegalArgumentException: LoggerFactory is not a Logback LoggerContext but Logback is on the classpath. Either remove Logback or the competing implementation (class org.slf4j.impl.Log4jLoggerFactory loaded from file:/E:/apache-maven-3.5.4/repository/org/slf4j/slf4j-log4j12/1.7.29/slf4j-log4j12-1.7.29.jar). If you are using WebLogic you will need to add 'org.slf4j' to prefer-application-packages in WEB-INF/weblogic.xml: org.slf4j.impl.Log4jLoggerFactory
	at org.springframework.util.Assert.instanceCheckFailed(Assert.java:696)

docker 下zookeeper的启动命令

docker run -p 8080:8080 --name zookeeper-standalone --restart always -d zookeeper

shell面板

docker exec -it c08a zkCli.sh

UnKNowHostException

@Configuration
public class ApplicationContextConfig {

    @Bean
    @LoadBalanced //赋予resttemple负载均衡的能力
    public RestTemplate getRestTemplate(){
        return new RestTemplate();
    }
}

springcloud ribbon

消费者方

负载均衡算法

package com.example.myrule;
@Configuration
public class MySelfRule {
    @Bean
    public IRule myRule(){
        return new Randomrule();
    }
}

接口

public interface LoadBalancer {

     ServiceInstance instances(List<ServiceInstance> serviceInstances);
}

实现类

@Component
public class MyLB implements LoadBalancer {

    private AtomicInteger atomicInteger=new AtomicInteger(0);

    public final int getAndIncrement(){
        int current;
        int next;
        do {
            current=this.atomicInteger.get();
          next = current > Integer.MAX_VALUE ? 0 : current + 1;
        }while (!this.atomicInteger.compareAndSet(current,next));
        return next;
    }
    @Override
    public ServiceInstance instances(List<ServiceInstance> serviceInstances) {
        int index = getAndIncrement() % serviceInstances.size();
        return serviceInstances.get(index);
    }
}

CAS+自旋锁

config

@Configuration
public class ApplicationContextConfig {

    @Bean
//    @LoadBalanced //赋予resttemple负载均衡的能力
    public RestTemplate getRestTemplate(){
        return new RestTemplate();
    }
}

controller

@RestController
public class OrderController {
    //public static final String PAYMENT_URL = "http://localhost:8001";
    public static final String PAYMENT_URL = "http://MicroServivceName";
    @Resource
    private RestTemplate restTemplate;
    /**
    * 自定义负载均衡算法
    */
    @Resource
    private LoadBalancer loadBalancer;
    @Resource
    private discoveryClient discoveryClient;

   

    @GetMapping("/consumer/loadbalancer")
    public String getPaymentLB() {
        List<ServiceInstance> instances = discoveryClient.getInstances("SERVICE-NAME");
        if (instances == null || instances.size() <= 0) {
            return null;
        }
        ServiceInstance serviceInstance = loadBalancer.instances(instances);
        URI uri = serviceInstance.getUri();

        return restTemplate.getForObject(uri+"/payment/lb",String.class);
    }
}

springcloud openfeign

服务调用

消费者微服务模块中service接口中加@FeignClient

service:

@FeithClient(value="MicroServiceName")
public interface FeignService(){
    @GetMapping("/name/{id}")
    public  Result getById(Integer id);
}

controller:

public class FeignController{
    @Resource
    private FeignService feignService;
    @GetMapping("/get/{id}")
    public Result order(@PathVariable Integer id ){
     	return   feignService.getById(id);
    }
}
openfeign超时控制

feign客户端认等待一秒钟,超时就报错,

openFeign是由ribbon组成,修改ribbon的yml配置项即可

ribbon:
	ReadTimeout:5000
	ConnectTimeOut:5000
openfeign日志打印功能

日志级别:NONE:不显示日志

BASIC:请求方法、url、、相应状态码、执行时间

HEADERS:请求方法、url、、相应状态码、执行时间,有请求和响应的头信息

FULL:请求方法、url、、相应状态码、执行时间,有请求和响应的头信息,还有请求和响应的正文和元数据

方法

配置类

@configuration
public class feignConfig{
    @Bean
    Logger.level FeignLoggerLevel(){
        return Logger.Level.Full;
    }
}

YML

logger:
	level:
	#Feign日志是什么级别监控那个接口
	com.springcloud.service.PaymentService:debug

版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 [email protected] 举报,一经查实,本站将立刻删除。

相关推荐