Ubuntu22.04 - etcd的安装和使用

介绍

Etcd 是一个 golang 编写的分布式、高可用的一致性键值存储系统，用于配置共享和服务发现等。它使用 Raft 一致性算法来保持集群数据的一致性，且客户端通过长连接watch 功能，能够及时收到数据变化通知，相较于 Zookeeper 框架更加轻量化。以下是关于 etcd 的安装与使用方法的详细介绍。

安装Etcd

Etcd 是一个分布式键值存储，通常用于服务发现和配置管理。
1.安装Etcd
sudo apt-get install etcd
2.节点配置
vi /etc/default/etcd
这是服务器监听的地址


3.启动etcd服务
systemctl start etcd
4. 运行验证
etcdctl put mykey "this is awesome"
如果出现报错:

则 vi /etc/profile在末尾声明环境变量ETCDCTL_API=3以确定etcd版本

完毕后, 加载配置文件source /etc/profile, 并重新执行测试指令

安装etcd的客户端

etcd-cpp-apiv3: etcd-cpp-apiv3 是一个 etcd 的 C++版本客户端 API。它依赖于 mipsasm, boost, protobuf, gRPC, cpprestsdk 等库。

依赖安装:
sudo apt-get install libboost-all-dev libssl-dev
sudo apt-get install libprotobuf-dev protobuf-compiler-grpc
sudo apt-get install libgrpc-dev libgrpc++-dev
sudo apt-get install libcpprest-dev

去github上下载https://github.com/etcd-cpp-apiv3/etcd-cpp-apiv3.git

依次执行:
unzip etcd-cpp-apiv3-master.zip
cd etcd-cpp-apiv3-master
mkdir build && cd build
cmake .. -DCMAKE_INSTALL_PREFIX=/usr
make -j$(nproc) && sudo make install

使用

示例:
put.cc文件

#include <etcd/Client.hpp>
#include <etcd/KeepAlive.hpp>
#include <etcd/Response.hpp>
#include <thread>int main(int argc, char* argv[])
{std::string etcd_host = "http://127.0.0.1:2379";// 实例化客户端对象etcd::Client client(etcd_host);// 获取/创建租约保活对象 -- 能指定有效时长的租约auto keep_alive = client.leasekeepalive(3).get();//leasekeepalive会创建一个keepalive对象(创建对象的时候, 会自动有一个ID)//为什么还要get? pplx::task<std::shared_ptr<KeepAlive>> leasekeepalive(int ttl); 返回一个task, task取到里面的类型需要用get//auto 的类型为智能指针// 获取租约IDauto lease_id = keep_alive->Lease();// 向etcd新增数据auto resp = client.put("/service/user", "127.0.0.1:8080", lease_id).get();//pplx::task<Response> put(...)/*class Response{bool is_ok()std::string const& error_message()Value const& value()//当前的数值 或者 一个请求的处理结果Value const& prev_value()//之前的数值Value const& value(int index)};*/if(resp.is_ok() == false) {std::cout << "新增数据失败: " << resp.error_message() << std::endl;return -1;}//keepalive会和etcd服务端建立长连接, 创建一个ID, 并一直发送心跳包, 发送ttl秒, 然后客户端拿着这个ID去put, 这样就建立起了联系//如果服务器没接收到心跳包了, 则会将有这个ID的数据删除auto resp2 = client.put("/service/friend", "127.0.0.1:9090").get();if (resp2.is_ok() == false) {std::cout << "新增数据失败: " << resp2.error_message() << std::endl;return -1;}std::this_thread::sleep_for(std::chrono::seconds(10)); //阻塞休息10sreturn 0;
}

get.cc文件

#include <etcd/Client.hpp>
#include <etcd/KeepAlive.hpp>
#include <etcd/Response.hpp>
#include <etcd/Watcher.hpp>
#include <etcd/Value.hpp>
#include <thread>void callback(const etcd::Response& resp){if (resp.is_ok() == false) {std::cout << "收到一个错误的事件通知:" << resp.error_message() << std::endl;return;}for (auto const& ev : resp.events()) {if (ev.event_type() == etcd::Event::EventType::PUT) {std::cout << "服务信息发生了改变:\n";std::cout << "当前的值: " << ev.kv().key() << "-" << ev.kv().as_string() << std::endl;std::cout << "原来的值: " << ev.prev_kv().key() << "-" << ev.prev_kv().as_string() << std::endl;} else if (ev.event_type() == etcd::Event::EventType::DELETE_) {std::cout << "服务信息下线被删除:\n";std::cout << "当前的值: " << ev.kv().key() << "-" << ev.kv().as_string() << std::endl;std::cout << "原来的值: " << ev.prev_kv().key() << "-" << ev.prev_kv().as_string() << std::endl;}}
}int main(int argc, char* argv[])
{std::string etcd_host = "http://127.0.0.1:2379";// 实例化客户端对象etcd::Client client(etcd_host); //pplx::task<Response> ls// 获取制定的键值对信息auto resp = client.ls("/service").get();            //key也分为目录     key1/a/111    key1/b/111  key/a/111/222if (resp.is_ok() == false) {std::cout << "获取键值对数据失败: " << resp.error_message() << std::endl;return -1;}int sz = resp.keys().size();for (int i = 0; i < sz; ++i) {std::cout << resp.value(i).as_string() << "可以提供" << resp.key(i) << "服务\n";}// 实例化一个键值对事件监控对象auto watcher = etcd::Watcher(client, "/service", callback, true);watcher.Wait();     //会一直循环return 0;
}

运行: