Я пытаюсь настроить простое обнаружение, используя spring-boot-kubernetes, но каждый раз при получении соединения отказывается при попытке превышения службы по имени службы.
Я включил:
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-kubernetes</artifactId>
</dependency>
И добавил аннотацию @EnableDiscoveryClient.
Ниже приведен файл deploy.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
Ниже приведена deploy.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();
}
Каждый раз, когда я пытаюсь вызвать ошибка конечной точки ниже появляется в журналах и пользовательском интерфейсе.
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 description sv c sample-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>