Technology sharing

한어Русский языкEnglishFrançaisIndonesianSanskrit日本語DeutschPortuguêsΕλληνικάespañolItalianoSuomalainenLatina

Ordinatio muneris exsecutionem distribuit secundum Zookeeper

Salve omnes, ego sum editor Weizhuan Taoke System 3.0, et sum etiam programmator qui non longas morigeras in hieme, sed adhuc frigida tempestate frigus habet!

Zookeeper 1. Quid est?

Zookeeper aperta est fons schedula coordinationis distributa muneris, quae efficientes datas administrationes distribuit et facultates coordinationis praebet. Maxime adhibetur ad solidam datam solvendam problematum in applicationibus distributis, ut servitium adnotationes et inventionis, comae distributae, schematismi administrationis, etc.

2. Integrate Zookeeper in Spring Boot

In Tabernis Spring propositi, Zookeeper uti possumus ad operas coordinationis distributas efficiendas. Deinde quomodo configurare, connectere et uti Zookeeper inducemus.

2.1.

Primum in Booz verpom.xmlZookeeper clientelas addere:

<dependency>
    <groupId>org.apache.zookeeper</groupId>
    <artifactId>zookeeper</artifactId>
    <version>3.7.0</version>
</dependency>
<dependency>
    <groupId>org.apache.curator</groupId>
    <artifactId>curator-framework</artifactId>
    <version>5.1.0</version>
</dependency>
1
2
3
4
5
6
7
8
9
10

2.2.

existapplication.propertiesConfigurare Zookeeper nexu information:

zookeeper.connect-string=localhost:2181
1

2.3.

Partum a Zookeeper operandi genus ad connectendum et operandum Zookeeper:

package cn.juwatech.zookeeper;

import org.apache.curator.framework.CuratorFramework;
import org.apache.curator.framework.CuratorFrameworkFactory;
import org.apache.curator.retry.ExponentialBackoffRetry;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Service;

import javax.annotation.PostConstruct;

@Service
public class ZookeeperService {

    @Value("${zookeeper.connect-string}")
    private String connectString;

    private CuratorFramework client;

    @PostConstruct
    private void init() {
        client = CuratorFrameworkFactory.newClient(connectString, new ExponentialBackoffRetry(1000, 3));
        client.start();
    }

    public void createNode(String path, byte[] data) throws Exception {
        client.create().creatingParentsIfNeeded().forPath(path, data);
    }

    public void setData(String path, byte[] data) throws Exception {
        client.setData().forPath(path, data);
    }

    public byte[] getData(String path) throws Exception {
        return client.getData().forPath(path);
    }

    public void deleteNode(String path) throws Exception {
        client.delete().deletingChildrenIfNeeded().forPath(path);
    }

    public void close() {
        client.close();
    }
}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44

2.4.

In sample codice monstramus quomodo Zookeeper uti ad efficiendum simplicem seram distributam;

package cn.juwatech.zookeeper;

import org.apache.curator.framework.recipes.locks.InterProcessMutex;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import javax.annotation.PostConstruct;

@Service
public class DistributedLockService {

    @Autowired
    private ZookeeperService zookeeperService;

    private InterProcessMutex lock;

    @PostConstruct
    private void init() {
        lock = new InterProcessMutex(zookeeperService.getClient(), "/distributed-lock");
    }

    public void acquireLock() throws Exception {
        lock.acquire();
    }

    public void releaseLock() throws Exception {
        lock.release();
    }
}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29

3. Libri

Articulus hic inducit quomodo ad integrandum et usum Zookeeper in Ver Tabernis project ad efficiendum officia coordinationis distributa, inclusis gradibus clavis ut configurationis dependentiae, connectens Zookeeper, ac comam distribuit exsequendam. Per exempla haec, tincidunt melius intellegere possunt et principales partes Zookeeper in systematis distributis applicare.

Productus ab editore Micro-commerce Taoke System 3.0, necesse est esse productum quale.