当前位置: 首页 > article >正文

spring boot连接clickhouse集群,实现故障节点自动切换

程序去连接clickhouse集群,要求当连接到故障节点时,可以自动去连接后面的可用节点,实现高可用。

1. 新建ClickhouseDatasource,使用自定义的datasource

   @Bean(name="clickHouseDataSource")
    public DataSource clickHouseDataSource() throws Exception {
        ClickHouseDataSourceWithFailover datasource = new ClickHouseDataSourceWithFailover(ConnectInfo.ckIPs, userName, password, 5000);
        return datasource;
    }

2. 自定义ClickHouseDataSourceWithFailover,连接失败时自动连接下一个节点

public class ClickHouseDataSourceWithFailover extends ClickHouseDataSource {
    private final List<String> nodes;
    private final String username;
    private final String password;
    private final int timeout;

    public ClickHouseDataSourceWithFailover(List<String> nodes, String username, String password, int timeout) throws SQLException {
        super(String.format("jdbc:clickhouse://%s:8123/audit?connect_timeout=%d&socket_timeout=500000", nodes.get(0), timeout));
        this.nodes = nodes;
        this.username = username;
        this.password = password;
        this.timeout = timeout;
    }

    @Override
    public ClickHouseConnection getConnection() throws SQLException {
        for (String node : nodes) {
            try {
                String url = String.format("jdbc:clickhouse://%s:8123/db?connect_timeout=%d&socket_timeout=500000", node, timeout);
                Properties properties = new Properties();
                properties.put("username", username);
                properties.put("password", password);

                ClickHouseDataSource dataSource = new ClickHouseDataSource(url, properties);
                return dataSource.getConnection();
            } catch (SQLException e) {
                log.error("Failed to connect to node: {}, ex:{}", node, e);
            }
        }
        throw new SQLException("Unable to connect to any ClickHouse node.");
    }
}


http://www.kler.cn/a/588859.html

相关文章:

  • Python基于深度学习的多模态人脸情绪识别研究与实现
  • 【TCP】三次挥手,四次挥手详解--UDP和TCP协议详解
  • 【LeetCode110】平衡二叉树
  • 爬虫获取 item_get_video 接口数据:小红书笔记视频详情的深度解析
  • Docker 端口映射的 “隐藏炸弹“ 与安全访问方案
  • 第二十七天 实践分布式任务调度,实现一个简单的分布式任务
  • Linux内核邻接子系统分析
  • PHP与前端框架的无缝集成:最佳实践与案例分析
  • 【Linux篇】初识Linux指令(下篇)
  • 【部署】ubuntu部署olmOCR
  • DICT领域有哪些重要的技术标准和规范?
  • 国科大——计网(0812)——考试真题
  • 96.HarmonyOS NEXT工具类设计模式教程:最佳实践与实现
  • 项目--五子棋(前置知识)
  • win32汇编环境,对 WM_MOUSEMOVE 消息的理解
  • kotlin中的界面组件
  • 视频编码中视频帧的类型解析
  • (分块)洛谷 P2801 教主的魔法 题解
  • 上传本地项目到GitHub
  • windows系统amd核显机器安装cpu版本pytorch(仅用于学习)