Neo4j 和 haproxy：一些最佳实践和技巧

该博客文章的目标是提供适合大多数 neo4j 集群的合理 haproxy 配置。它涵盖了适用于典型部署的 Neo4j 特定需求（身份验证、粘性、请求路由）。

一些介绍的话

在运行 neo4j 集群时，您通常希望在其前面放置一个负载均衡器。负载均衡器本身不是 neo4j 的一部分，因为很多客户已经在他们的基础设施中安装了硬件负载均衡器。如果他们没有或想要一些易于使用的解决方案，推荐的工具是 haproxy 。

在 Neo4j 集群中，它完全有可能在任何集群成员上运行任何操作（读取和写入）。然而在性能方面，将写请求直接发送到主节点并将只读请求发送到所有集群成员或仅发送到从节点是一个好主意——这取决于你的主节点有多忙。

我们需要涵盖的内容

如今，大多数人通过事务密码端点发送密码命令来与 Neo4j 交互。此端点始终使用 http post，无论密码命令是否旨在执行读取或写入操作。这会给负载平衡带来一些痛苦，因为我们需要区分读取和写入。

一种方法是在客户端使用额外的自定义 HTTP 标头。假设任何应该执行写入的请求都会在请求中获得一个 x-write:1 标头。然后 haproxy 只需要在 acl 中检查此标头，并将此 acl 与仅包含主实例的后端相关联。

另一个想法是负载平衡器检查请求的有效负载（也就是您发送的密码命令）。如果该有效负载包含诸如创建、合并、设置、删除、删除或 foreach 之类的写子句，则很可能是将写入操作定向到主服务器。幸运的是 haproxy 有能力检查有效负载并应用正则表达式匹配。

第三种方法是将每个用例封装到一个非托管扩展中，并在内部使用密码、遍历 api 或核心 api 作为实现细节。通过适当地使用 rest 的语义，您可以使用 get 来实现无副作用的读取，使用 put、post 和 delete 来实现写入。这些也可以很容易地用在 haproxy 的 acl 中。

设置负载均衡器时我们必须处理的另一个问题是身份验证。从 neo4j 2.2 开始，数据库默认使用用户名和密码进行保护。当然我们可以关闭该功能，但如果安全是一个问题，那么启用它是明智的。结合 haproxy 我们需要知道 haproxy 需要使用身份验证以及它的状态检查来识别谁可用和谁是主人。

推荐设置

我花了一些时间来解决上述所有问题的 haproxy 配置。让我们逐行浏览下面的相关部分——剩下的我委托给 haproxy 的优秀文档。请注意，此配置需要最新版本的 haproxy：

global daemon maxconn 256 stats socket /var/run/haproxy.sock mode 600 level admin stats timeout 2m defaults mode http option httplog timeout connect 5000ms timeout client 50000ms timeout server 50000ms frontend http-in bind *:8090 acl write_method method post delete put acl write_hdr hdr_val(x-write) eq 1 acl write_payload payload(0,0) -m reg -i create|merge|set|delete|remove acl tx_cypher_endpoint path_beg /db/data/transaction http-request set-var(txn.tx_cypher_endpoint) bool(true) if tx_cypher_endpoint use_backend neo4j-master if write_hdr use_backend neo4j-master if tx_cypher_endpoint write_payload use_backend neo4j-all if tx_cypher_endpoint use_backend neo4j-master if write_method default_backend neo4j-all backend neo4j-all option httpchk get /db/manage/server/ha/available http/1.0\r\nauthorization:\ basic\ bmvvngo6mtiz #option httpchk get /db/manage/server/ha/available acl tx_cypher_endpoint var(txn.tx_cypher_endpoint),bool stick-table type integer size 1k expire 70s # slightly higher with org.neo4j.server.transaction.timeout stick match path,word(4,/) if tx_cypher_endpoint stick store-response hdr(location),word(6,/) if tx_cypher_endpoint server s1 127.0.0.1:7474 maxconn 32 check server s2 127.0.0.1:7475 maxconn 32 check server s3 127.0.0.1:7476 maxconn 32 check backend neo4j-master option httpchk get /db/manage/server/ha/master http/1.0\r\nauthorization:\ basic\ bmvvngo6mtiz #option httpchk get /db/manage/server/ha/master server s1 127.0.0.1:7474 maxconn 32 check server s2 127.0.0.1:7475 maxconn 32 check server s3 127.0.0.1:7476 maxconn 32 check