不需要使用Spring的嵌入式发现服务
创始人
2025-01-10 15:00:13
0
  1. 使用 Spotify 的 Java 客户端库,在项目中添加以下依赖:

    com.spotify
    docker-client
    8.16.0

  1. 创建一个服务发现类,该类负责查询 Docker Swarm 集群中运行的服务:
import com.spotify.docker.client.DockerClient;
import com.spotify.docker.client.DockerClient.ListServicesParam;
import com.spotify.docker.client.DockerClient.ListTasksParam;
import com.spotify.docker.client.DockerClient.ListTasksParamBuilder;
import com.spotify.docker.client.exceptions.DockerCertificateException;
import com.spotify.docker.client.exceptions.DockerException;
import com.spotify.docker.client.messages.swarm.Service;
import com.spotify.docker.client.messages.swarm.Task;

import java.util.ArrayList;
import java.util.List;
import java.util.stream.Collectors;

public class DockerSwarmServiceDiscovery {
    
    private final DockerClient dockerClient;
    
    public DockerSwarmServiceDiscovery() throws DockerCertificateException {
        this.dockerClient = DefaultDockerClient.fromEnv().build();
    }
    
    public List getServiceEndpoints(String serviceName) {
        try {
            final List services = this.dockerClient.listServices(ListServicesParam.create().serviceName(serviceName)).stream().filter(s -> s.spec().name().equals(serviceName)).collect(Collectors.toList());
            final List endpoints = new ArrayList<>();
            
            for (Service service : services) {
                final ListTasksParamBuilder tasksParamBuilder = ListTasksParam.builder().serviceId(service.id());
                
                final List tasks = this.dockerClient.listTasks(tasksParamBuilder.build());
                
                for (Task task : tasks) {
                    endpoints.add(String.format("%s:%d", task.status().containerStatus().containerId(), task.status().containerStatus().ports().get(0).publicPort()));
                }
            }
            
            return endpoints;
        } catch (DockerException | InterruptedException e) {
            throw new RuntimeException("Error providing service endpoints", e);
        }
    }
}
  1. 在需要使用服务的代码中,实例化上述服务发现类并查询指定服务的 IP 和端口:
final DockerSwarmService

相关内容

热门资讯

今天上午!福建大菠萝万能辅助器... 今天上午!福建大菠萝万能辅助器(透视)欢乐达人最新版破解版(果然真的有辅助插件)-哔哩哔哩1、超多福...
今天上午!约局吧作必弊脚本(透... 今天上午!约局吧作必弊脚本(透视)九酷众娱辅助(果然有辅助平台)-哔哩哔哩1、进入到约局吧作必弊是否...
有玩家发现!wepoker免费... 有玩家发现!wepoker免费脚本咨询(透视)wepoker透视脚本下载(确实真的是有辅助软件)-哔...
透视最新!wepoker辅助透... 透视最新!wepoker辅助透视(透视)广西老友玩友破解吗(总是真的是有辅助软件)-哔哩哔哩1、游戏...
透视苹果版!wepoker私人... 透视苹果版!wepoker私人局有透视吗(透视)四川游戏家园辅助软件(确实真的有辅助修改器)-哔哩哔...
透视软件!wepoker好友局... 透视软件!wepoker好友局透视(透视)福建13水有挂吗(真是存在有辅助安装)-哔哩哔哩1、福建1...
一直以来!aapoker ai... 一直以来!aapoker ai插件(透视)潮友会鱼虾蟹脚本辅助器(都是是有辅助插件)-哔哩哔哩1、用...
透视安卓版!德普之星app安卓... 透视安卓版!德普之星app安卓版破解版(透视)花花生活圈怎么开挂(果然是真的辅助平台)-哔哩哔哩1、...
透视挂透视!哈糖大菠萝有挂吗5... 透视挂透视!哈糖大菠萝有挂吗5个常用方法(透视)福建大玩家万能辅助器(竟然是有辅助修改器)-哔哩哔哩...
有玩家发现!wepoker轻量... 有玩家发现!wepoker轻量版有透视吗(透视)杭州都莱辅助软件(确实真的有辅助修改器)-哔哩哔哩1...