Connect拒绝使用Spring Boot发现Kubernetes服务

Question

我试图使用spring-boot-kubernetes建立一个简单的发现，但是每次当我试图通过服务名提供额外的服务时，连接都被拒绝。

我包括：

        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-kubernetes</artifactId>
        </dependency>

并添加了@EnableDiscoveryClient注释。

下面是我试图通过名称从另一个服务调用的服务的deployment.yml。

kind: Service
apiVersion: v1
metadata:
  name: sample-rest
spec:
  selector:
    app: sample-rest
  ports:
    - protocol: TCP
      port: 8771
      targetPort: 8771
  type: NodePort

---

apiVersion: apps/v1
kind: Deployment
metadata:
  labels:
    app.kubernetes.io/name: sample-rest
  name: sample-rest
spec:
  replicas: 1
  selector:
    matchLabels:
      app.kubernetes.io/name: sample-rest
  template:
    metadata:
      labels:
        app.kubernetes.io/name: sample-rest
    spec:
      containers:
       - name: sample-rest
         image: kryptonian/sample-rest:1.0
         ports:
         - containerPort: 8771

下面是发现服务的deployment.yml，我试图在其中通过名称调用上面的服务。

kind: Service
apiVersion: v1
metadata:
  name: sample-discovery
spec:
  selector:
    app: sample-discovery
  ports:
    - protocol: TCP
      port: 8772
      targetPort: 8772
  type: NodePort

---

apiVersion: apps/v1
kind: Deployment
metadata:
  labels:
    app.kubernetes.io/name: sample-discovery
  name: sample-discovery
spec:
  replicas: 1
  selector:
    matchLabels:
      app.kubernetes.io/name: sample-discovery
  template:
    metadata:
      labels:
        app.kubernetes.io/name: sample-discovery
    spec:
      containers:
       - name: sample-discovery
         image: kryptonian/discovery-sample:1.0
         ports:
         - containerPort: 8772

调用服务的代码：

@GetMapping("/test")
    public String getHelloMessage() {

        RestTemplate restTemplate = new RestTemplate();

        String url = "http://sample-rest:8771/sample";

        ResponseEntity<String> result = restTemplate.getForEntity(url, String.class);

        return result.getBody();
    }

每次我尝试调用下面的endpoint时，日志和用户界面都会出现错误。

2020-04-13 16:08:04.187 ERROR 1 --- [nio-8772-exec-5] o.a.c.c.C.[.[.[/].[dispatcherServlet]    : Servlet.service() for servlet [dispatcherServlet] in context with path [] threw exception [Request processing failed; nested exception is org.springframework.web.client.ResourceAccessException: I/O error on GET request for "http://sample-rest:8771/sample": Connection refused (Connection refused); nested exception is java.net.ConnectException: Connection refused (Connection refused)] with root cause

java.net.ConnectException: Connection refused (Connection refused)
        at java.net.PlainSocketImpl.socketConnect(Native Method) ~[na:1.8.0_212]
        at java.net.AbstractPlainSocketImpl.doConnect(AbstractPlainSocketImpl.java:350) ~[na:1.8.0_212]
        at java.net.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocketImpl.java:206) ~[na:1.8.0_212]

kubectl的输出描述svc样本Rest

Name:                     sample-rest
Namespace:                default
Labels:                   <none>
Annotations:              kubectl.kubernetes.io/last-applied-configuration:
                            {"apiVersion":"v1","kind":"Service","metadata":{"annotations":{},"name":"sample-rest","namespace":"default"},"spec":{"ports":[{"port":8771...
Selector:                 app=sample-rest
Type:                     NodePort
IP:                       10.35.250.117
Port:                     <unset>  8771/TCP
TargetPort:               8771/TCP
NodePort:                 <unset>  31406/TCP
Endpoints:                <none>
Session Affinity:         None
External Traffic Policy:  Cluster
Events:                   <none>

Answer 1

这里的问题是服务＜code＞sample rest＜/code＞的endpoint为空。您应该检查您的服务的＜code＞spec.selector＜/code〕字段是否实际选择了Pods上的＜code>元数据标签＜/code>值。有app:sample-rest作为spec.selector，但pod标签有app.kubernetes.io/name:sample-rest不匹配。

https://kubernetes . io/docs/tasks/debug-application-cluster/debug-service/# do-the-service-have-any-endpoints

您也可以尝试绕过服务直接连接到POD IP，以确定这是否是服务的问题。