目录
- 介绍
- 安装Etcd
- 安装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 的类型为智能指针
// 获取租约ID
auto 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)); //阻塞休息10s
return 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/222
if (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;
}
运行:
