我试图使用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>
这里的问题是服务<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,以确定这是否是服务的问题。