最近有不少朋友在询问宝贝鱼(CshBBrain)集群的问题，说集群老不成功，本篇文章主要就是解答这个问题的。
首先介绍下宝贝鱼(CshBBrain)中集群相关的几个概念：
1.集群开关参数clustersSwitch：参数取值1表示打开集群开关，服务器将作为集群中的一个节点（可能只担当管理集群中其他服务器的角色，也可能只担当集群中的一个业务节点服务器角色，也可能2者兼任），总之要启用集群，必须将启动的服务器实例的这个参数配置为1.
2.管理服务器（master server）：参数clustersRole配置为2，在集群中只担当管理集群中的其他服务器的角色，定时收集监控集群中所管理服务器节点的配置信息、运行情况和负载；并担当集群中各服务器节点的负载分配和均衡。初步的想法是，客户端首先连接管理服务器，管理服务器根据集群中各服务器的负载状况和软硬件配置情况，给当前客户端分配一个节点服务器，客户端和分配的节点服务器建立连接进行后续的业务交互处理。
3.业务节点服务器（biz server）：参数clustersRole配置为1，在集群中只担当业务处理接入节点服务器，启动后首先连接到集群中指定的管理服务器（master server），汇报节点的软硬件配置（最重要的是要告诉管理服务器他的ip地址和客户端接入的端口），然后等待客户端请求的到来，并定时汇报自身的负载状况给管理服务器。
4.在有些时候可能不需要一台单独的管理服务器，那么你可以将其中1台服务器配置即为管理服务器（master server）又是业务节点服务器（biz server），你只需要将参数clustersRole配置为3.
5.端口参数详解：
5.1参数port：不管是管理服务器，还是业务服务器，该端口都是用来监听客户端建立连接的端口。
5.2参数clustersPort：管理服务器和业务服务器之间建立连接，相互通信的端口；管理服务器配置这个端口用于监听业务服务器建立连接的请求，业务服务器配置这个端口主要用于监听来至其他业务服务器的连接请求以及交互需要。
5.3参数masterServer：管理服务器的ip地址和端口号码，具有业务服务器角色的服务器需要配置他所归属的管理服务器，管理服务器不需要配置这个参数。
6.手把手教你配置集群：
6.1配置启动纯管理服务器节点：
6.1.1将配置文件config_1.properties的内容拷贝到config.properties中，注意将clustersRole设置为2，具体内容如下：
#the port of the server
port=9090
#the priority of the thread in pool
maxPriority=5
#the tmp folder
tmpRoot=e:/tmp/
#the factor of the work process thread per CPU kernel
requestWorker=5
#the factor of the read writer monitor thread per CPU kernel
monitorWorker=1
#the buffer size of the read buffer,unit is KB
readBuffer=5
#the buffer size of the write buffer,unit is KB
writeBuffer=64
#the send buffer size of the system sockect
sockectSendBufferSize=64
#the receive buffer of the system socket
sockectReceiveBufferSize=5
#wheather the connection keep alive,1:keep alive,0:not keep alive
keepConnect=1
#the count of blank read
zoreFetchCount = 1000000
#the min size and the max size of the buffer pool
minBufferPoolSize=1000
maxBufferPoolSize=1000
#whether open the broadcast thread,0:close,1:open
broadSwitch=0
#the timeout for every client,0:validate all the time,not 0:the timeout minites
timeOut=0
#the cluseter switch,0:close,1:open
clustersSwitch=1
#the cluseter port for the server
clustersPort=9191
#the responsibility of the server,1:biz server,2:master server,3:biz and master server
clustersRole=2
#the master server address,include the ip and port
#masterServer=192.168.1.220:9292
6.1.2打开ClustersServer文件，运行，启动成功后后台输出如下信息：
22:48:31,781 INFO MasterServer:554 - 数据读取回写监听线程创建成功：请求数据传输监听线程0
22:48:31,781 INFO MasterServer:953 - 请求处理调度线程创建完毕
22:48:31,781 INFO MasterServer:554 - 数据读取回写监听线程创建成功：请求数据传输监听线程1
22:48:31,796 INFO MasterServer:953 - 请求处理调度线程创建完毕
22:48:31,796 INFO MasterServer:1095 - 连接监听线程创建成功
22:48:31,796 INFO MasterServer:1126 - 集群连接监听线程创建成功
22:48:31,812 INFO MasterServer:1158 - 集群服务器准备就绪，等待集群请求到来
22:48:31,812 INFO MasterServer:1221 - 服务器准备就绪，等待请求到来
6.2配置启动纯业务节点服务器：
6.2.1将配置文件config_2.properties的内容拷贝到config.properties中，注意将clustersRole设置为1，具体内容如下：
#the port of the server
port=7070
#the priority of the thread in pool
maxPriority=5
#the tmp folder
tmpRoot=e:/tmp/
#the factor of the work process thread per CPU kernel
requestWorker=5
#the factor of the read writer monitor thread per CPU kernel
monitorWorker=1
#the buffer size of the read buffer,unit is KB
readBuffer=5
#the buffer size of the write buffer,unit is KB
writeBuffer=64
#the send buffer size of the system sockect
sockectSendBufferSize=64
#the receive buffer of the system socket
sockectReceiveBufferSize=5
#wheather the connection keep alive,1:keep alive,0:not keep alive
keepConnect=1
#the count of blank read
zoreFetchCount = 1000000
#the min size and the max size of the buffer pool
minBufferPoolSize=1000
maxBufferPoolSize=1000
#whether open the broadcast thread,0:close,1:open
broadSwitch=0
#the timeout for every client,0:validate all the time,not 0:the timeout minites
timeOut=0
#the cluseter switch,0:close,1:open
clustersSwitch=1
#the cluseter port for the server
clustersPort=7171
#the responsibility of the server,1:biz server,2:master server,3:biz and master server
clustersRole=1
#the master server address,include the ip and port
masterServer=192.168.1.220:9191 （注意：因为管理服务器的clustersPort配置为9191，所以业务节点服务器这里的端口要配置为9191）
6.1.2打开Server文件，运行，启动成功后后台输出如下信息：
22:48:57,828 INFO MasterServer:554 - 数据读取回写监听线程创建成功：请求数据传输监听线程0
22:48:57,828 INFO MasterServer:953 - 请求处理调度线程创建完毕
22:48:57,843 INFO MasterServer:554 - 数据读取回写监听线程创建成功：请求数据传输监听线程1
22:48:57,843 INFO MasterServer:953 - 请求处理调度线程创建完毕
22:48:57,843 INFO MasterServer:1095 - 连接监听线程创建成功
22:48:57,843 INFO MasterServer:1126 - 集群连接监听线程创建成功
22:48:57,843 INFO MasterServer:269 - 集群通信客户端消息处理线程创建完毕
22:48:57,859 INFO MasterServer:324 - 成功连接到集群服务器 192.168.1.220 的端口:9191
22:48:57,875 INFO MasterServer:1221 - 服务器准备就绪，等待请求到来
22:48:57,890 INFO MasterServer:1158 - 集群服务器准备就绪，等待集群请求到来
下面是握手信息：
22:48:57,921 INFO Client:844 - 向客户端null发送数据：CshBBrain
Host:192.168.1.220
Key:b9db05a1b940499da96b0dbb
Protocol:Protocol
22:48:57,921 INFO ClustersCoder:167 - the response: CshBBrain
Host:192.168.1.220
Key:b9db05a1b940499da96b0dbb
Protocol:Protocol
等几分钟，业务节点服务器后台会输入如下信息，是因为目前我只做了简单处理，在业务节点服务器把本身的负载等情况定时汇报给管理服务器时，管理服务器只简单的将节点服务器发来的信息返回，并在节点服务器端输出这些信息：
22:49:57,859 INFO MasterServer:377 - 节点服务器：192.168.1.220:1674
服务器CPU内核数量：2
服务器读写监听线程数量：2
服务器工作线程数量：10
活跃连接客户端数量：0
活跃集群连接客户端数量：0
活跃本地连接客户端数量：0
22:49:57,859 INFO Client:844 - 向客户端null发送数据：action=1&coreCount=2&readerWriterCount=2&workerCount=10&clientCount=0&clustersCount=0&port=7070&localCount=0
22:50:27,859 INFO MasterServer:377 - 节点服务器：192.168.1.220:1674
服务器CPU内核数量：2
服务器读写监听线程数量：2
服务器工作线程数量：10
活跃连接客户端数量：0
活跃集群连接客户端数量：0
活跃本地连接客户端数量：0
22:50:27,859 INFO Client:844 - 向客户端null发送数据：action=1&coreCount=2&readerWriterCount=2&workerCount=10&clientCount=0&clustersCount=0&port=7070&localCount=0
按照上面所说的配置你的集群，然后在此基础上扩展开发你自己的集群管理协调功能即可。
相关推荐
开源WebSocket服务器项目“宝贝鱼”（CshBBrain）提供了一个实现这一功能的解决方案。 CshBBrain V1.0.1是一个针对开发者的工具，它实现了WebSocket服务器的基本功能，并且是开源的，允许开发者根据自己的需求进行...
宝贝鱼（CshBBrain）是一个由中国开发者或团队创建的软件项目，它定位为一个简单、轻量级且性能高效的WebSocket服务器。WebSocket是一种在单个TCP连接上进行全双工通信的协议，它允许服务器向客户端主动发送信息，...
CshBBrainJS后面将支持 宝贝鱼(CshBBrain和CshBBrainAIO) 服务器集群功能。 CshBBrainJS不仅可以和开源WebSocket服务器项目 宝贝鱼(CshBBrain和CshBBrainAIO)配合使用，还可以与其他WebSocket服务器搭配使用。...
【CshBBrainAIO V4.0.3(宝贝鱼)】是一个基于Java平台的高级I/O（Asynchronous Input/Output，简称AIO）框架，通常用于开发高性能、高并发的网络应用。AIO与传统的IO模型不同，它允许程序在数据准备就绪后才进行实际...
【计算机求职笔试】资源
# 基于Apache Spark Mllib的Bronze机器学习平台 ## 项目简介 Bronze是一个构建在Apache Spark Mllib之上的机器学习平台，旨在提供全面的数据接入、转换、训练、测试和输出功能。该平台支持多种机器学习算法模型，并提供丰富的插件来处理数据预处理、特征工程、模型训练和验证等任务。 ## 项目的主要特性和功能 ### 数据处理流程 1. 数据采集从各种数据源（如Fake、File、HDFS）接入数据。 2. 数据预处理对数据进行清洗、转换和格式化。 3. 特征工程生成和选择特征，包括特征提取、转换和选择。 4. 模型训练使用多种分类和回归模型进行训练。 5. 模型验证对训练好的模型进行验证和评估。 6. 模型持久化将训练好的模型保存到持久化存储中。 7. 模型结果输出输出模型的最终结果。 ### 支持的算法模型 #### 分类模型 逻辑回归支持大规模特征和无限训练样例，输出类别数小于1000万。
Java项目基于Springboot框架的课程设计，包含LW+ppt
资源内项目源码是均来自个人的课程设计、毕业设计或者具体项目，代码都测试ok，都是运行成功后才上传资源，答辩评审绝对信服的，拿来就能用。放心下载使用！源码、数据集、部署说明一站式服务，拿来就能用的绝对好资源！！！ 项目备注 1、该资源内项目代码都经过测试运行成功，功能ok的情况下才上传的，请放心下载使用！ 2、本项目适合计算机相关专业(如计科、人工智能、通信工程、自动化、电子信息等)的在校学生、老师或者企业员工下载学习，也适合小白学习进阶，当然也可作为毕设项目、课程设计、大作业、项目初期立项演示等。 3、如果基础还行，也可在此代码基础上进行修改，以实现其他功能，也可用于毕设、课设、作业等。 下载后请首先打开README.dataset.txt文件，仅供学习参考, 切勿用于商业用途。 4、如有侵权请私信博主，感谢支持
内容概要：本文详细探讨了全球定位系统（GPS）的信号产生、捕获和追踪三个核心步骤，并通过Matlab源码实现相关算法。首先介绍了GPS信号产生的关键要素，包括伪随机码生成、数据编码和信号发射。接着讨论了信号捕获过程，涉及天线接收、码相位测量及其常用方法如滑动相关法。最后阐述了信号追踪的三边测量原理及误差修正措施，如电离层延迟补偿、地形效应补偿和多路径效应修正。通过具体Matlab代码示例展示了整个流程的实现，并附带了详细的运行步骤和结果分析。 适合人群：对GPS系统有兴趣的研究人员和技术爱好者，尤其是有一定编程基础并希望深入了解GPS内部机制的人群。 使用场景及目标：适用于学术研究、工程开发等领域，旨在帮助读者掌握GPS信号处理的基本理论和实践技能，提升定位精度和可靠性。 其他说明：文中提供的Matlab代码已在特定版本下测试通过，但不同版本可能存在差异。此外，还列举了一些参考文献供进一步学习。
基于Andorid条形二维码识别设计实现源码，主要针对计算机相关专业的正在做毕设的学生和需要项目实战练习的学习者，也可作为课程设计、期末大作业。
NRF24L01收发例程
AcWing算法基础课Notion笔记html页面
[Excel在财务管理中的应用（第六版）（微课版）]配书资源
# 基于多线程的Web客户端程序 ## 项目简介 本项目是一个基于多线程的Web客户端程序，旨在并发地从Web服务器获取多个文件。通过使用多线程技术，程序能够高效地处理多个文件请求，提高整体性能。 ## 项目的主要特性和功能 多线程并发请求支持同时从多个Web服务器获取文件，提高请求效率。 TCP连接管理每个线程负责建立TCP连接并发送HTTP GET请求。 线程同步与通信使用互斥锁和条件变量确保线程间的同步和数据一致性。 命令行参数解析支持解析命令行参数，获取连接的最大数量和要获取的文件列表。 文件处理每个线程负责读取服务器的响应并处理文件内容。 ## 安装使用步骤 1. 下载源码假设用户已经下载了本项目的源码文件。 2. 编译项目使用合适的编译器（如GCC）编译项目源码。 bash gcc o webclient main.c lpthread
中学学生“诚信”教育班会课件
1、文件说明： Centos8操作系统tacacs-devel-F4.0.4.28.7fb~20231005g4fdf178-2.el8.rpm以及相关依赖，全打包为一个tar.gz压缩包 2、安装指令： #Step1、解压 tar -zxvf tacacs-devel-F4.0.4.28.7fb~20231005g4fdf178-2.el8.tar.gz #Step2、进入解压后的目录，执行安装 sudo rpm -ivh *.rpm
内容概要：本文详细介绍了如何利用LabVIEW通过网口与西门子PLC进行高效通讯的方法和技术细节。首先解释了西门子S7Comm协议的三层结构（TPKT+COTP+S7），并通过具体实例展示了如何构造和发送十六进制命令帧。接着提供了完整的LabVIEW代码片段，涵盖从TCP连接建立、命令帧发送、响应接收及数据解析的全过程。文中还分享了多种实用技巧，如批量读写、强制写入、自动重连机制等，并对比了原生TCP与OPC UA的性能差异。最后，通过实际案例验证了该方案在工业应用中的优越性和稳定性。 适合人群：从事工业自动化领域的工程师和技术人员，尤其是熟悉LabVIEW和西门子PLC的用户。 使用场景及目标：适用于需要与西门子PLC进行高效、稳定的网口通讯的应用场景，旨在提高通讯效率、降低系统复杂度和成本。 其他说明：文中提供的代码和技巧可以帮助开发者更好地理解和掌握LabVIEW与西门子PLC之间的通讯机制，从而应用于各种工业控制系统中。
matlab
内容概要：本文详细介绍了基于CH579芯片的以太网转串口服务器的实现过程。首先，文章讲解了硬件配置，包括使用的芯片及其特性，如CH579M、PHY芯片HR911105A和电平转换电路SGM48017。接着，重点剖析了网络初始化代码，强调了PHY复位时序、MAC地址传递和硬件协议栈处理ARP和ICMP协议的重要性。随后，文章深入探讨了串口数据处理，展示了环形缓冲区的实现和中断服务函数的优化。此外，还介绍了协议转换的状态机实现，以及内存池分配的精妙之处。最后，文章总结了资源管理策略，如DMA自动搬运数据、中断嵌套机制和零拷贝技术，使得服务器能够实现稳定的3Mbps转发速率。 适合人群：具有一定嵌入式开发经验的研发人员，尤其是对以太网转串口服务器感兴趣的工程师。 使用场景及目标：适用于需要深入了解嵌入式系统中以太网转串口服务器的工作原理和技术实现的人群。目标是掌握CH579芯片的硬件配置、网络初始化、串口数据处理、协议转换和资源管理等方面的知识。 其他说明：文中提供了详细的代码示例和硬件设计要点，帮助读者更好地理解和应用相关技术。建议读者结合实际项目进行实践，逐步掌握核心技术。
Java项目基于Springboot框架的课程设计，包含LW+ppt