对于Flink中的每个并行任务,确实不希望每次map操作都创建一个新的Redis连接,这会导致连接的创建和销毁开销很大,同时也会影响性能。

为了避免这种情况,可以考虑使用Redis连接池来管理连接。连接池可以在初始化阶段创建一定数量的Redis连接,并将这些连接放入池中。然后,在map操作中,可以从连接池中获取一个可用的连接,并在操作完成后将连接归还给连接池。

这样,每个并行任务只需要在初始化阶段获取一次Redis连接,而不是每次map操作都创建一个新的连接。这可以大大减少连接的创建和销毁开销,提高性能。

常见的连接池框架有Jedis连接池和Lettuce连接池,可以根据具体的需求选择合适的连接池框架来管理Redis连接。同时,还需要注意在使用连接池时正确处理连接的获取和归还,以避免连接泄露或者连接被关闭的情况。

flink不希望每次map都创建一个redis连接

原文地址: https://www.cveoy.top/t/topic/iVc6 著作权归作者所有。请勿转载和采集!

免费AI点我,无需注册和登录