Zookeeper实现分布式锁和注册中心

分布式锁

实现方式

分布式锁场景如何选择Redis和zookeeper

用InterProcessMutex实现分布式锁

zookeeper实现注册中心

分布式锁

实现方式

数据库唯一索引
Redis的setnx
Zookeeper创建临时节点及监听机制
Zookeeper创建临时有序节点

分布式锁场景如何选择Redis和zookeeper

一致性：

ZooKeeper是一个分布式协调服务，它保证了强一致性。这意味着在ZooKeeper中创建的节点的状态是全局可见的，并且所有节点都将在相同的时间看到相同的数据。这种一致性可以确保分布式锁的可靠性。
Redis是一个支持分布式的缓存和数据存储，但其一致性较弱。Redis的主从复制模式可能会导致一些短暂的不一致，这可能影响分布式锁的可靠性。

性能：

Redis通常被认为是一个高性能的内存数据库，适用于需要快速读写操作的场景。如果你的系统对性能要求较高，而且可以容忍一些短暂的不一致，那么使用Redis可能是个不错的选择。
ZooKeeper的性能可能不如Redis那么高，因为它的设计目标更侧重于提供强一致性和可靠性。

部署和维护：

Redis相对较简单，容易部署和维护。你只需要关注Redis节点的可用性和性能。
ZooKeeper需要维护一个ZooKeeper集群，确保其正常运行可能需要更多的配置和管理。

用InterProcessMutex实现分布式锁

1. 引入curator依赖

        <dependency><groupId>org.apache.zookeeper</groupId><artifactId>zookeeper</artifactId><version>3.8.0</version></dependency><dependency><groupId>org.apache.curator</groupId><artifactId>curator-recipes</artifactId><version>5.1.0</version><exclusions><exclusion><groupId>org.apache.zookeeper</groupId><artifactId>zookeeper</artifactId></exclusion></exclusions></dependency>

2. java代码

public class CuratorLock {private final static  String CLUSTER_CONNECT_STR="192.168.6.128:2181,192.168.6.128:2182,192.168.6.128:2183";private static CuratorFramework client= CuratorFrameworkFactory.builder().connectString(CLUSTER_CONNECT_STR).retryPolicy(new ExponentialBackoffRetry(100,1)).build();static {client.start();}private static final InterProcessMutex lock = new InterProcessMutex(client,"/curator_lock");public static void main(String[] args) throws Exception {int count = 0;// 加锁lock.acquire();try {// 执行业务逻辑count++;} finally {// 解锁lock.release();}}
}

zookeeper实现注册中心

1. 引入依赖

    <parent><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-parent</artifactId><version>3.2.1</version><relativePath/> <!-- lookup parent from repository --></parent><properties><java.version>21</java.version><spring-boot.version>3.2.1</spring-boot.version><spring-cloud.version>2023.0.0</spring-cloud.version></properties><dependencies><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter</artifactId></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web-services</artifactId></dependency><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-zookeeper-discovery</artifactId><exclusions><exclusion><groupId>org.apache.zookeeper</groupId><artifactId>zookeeper</artifactId></exclusion></exclusions></dependency><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-openfeign</artifactId></dependency><!-- zookeeper client --><dependency><groupId>org.apache.zookeeper</groupId><artifactId>zookeeper</artifactId><version>3.8.0</version></dependency></dependencies><dependencyManagement><dependencies><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-dependencies</artifactId><version>${spring-cloud.version}</version><type>pom</type><scope>import</scope></dependency></dependencies></dependencyManagement>

2. 修改配置application.yml

spring:cloud:zookeeper:connect-string: 192.168.6.128:2181,192.168.6.128:2182,192.168.6.128:2183discovery:instance-host: 127.0.0.1application:name: user-service
server:port: 8081

3. 整合feign

@FeignClient(name = "order-service")
public interface OrderFeign {@GetMapping("/order/findById")String findOrder(@RequestParam("id") String id);
}@RequestMapping("/user")
@RestController
public class UserController {@Autowiredprivate OrderFeign orderFeign;@GetMapping("/findOrder")public String findOrder() {return orderFeign.findOrder("5");}
}

4. zookeeper会生成对应应用节点