最近有不少朋友在询问宝贝鱼(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模型不同,它允许程序在数据准备就绪后才进行实际...
qtz40塔式起重机总体及塔身有限元分析法设计().zip
Elasticsearch是一个基于Lucene的搜索服务器
资源内项目源码是来自个人的毕业设计,代码都测试ok,包含源码、数据集、可视化页面和部署说明,可产生核心指标曲线图、混淆矩阵、F1分数曲线、精确率-召回率曲线、验证集预测结果、标签分布图。都是运行成功后才上传资源,毕设答辩评审绝对信服的保底85分以上,放心下载使用,拿来就能用。包含源码、数据集、可视化页面和部署说明一站式服务,拿来就能用的绝对好资源!!! 项目备注 1、该资源内项目代码都经过测试运行成功,功能ok的情况下才上传的,请放心下载使用! 2、本项目适合计算机相关专业(如计科、人工智能、通信工程、自动化、电子信息等)的在校学生、老师或者企业员工下载学习,也适合小白学习进阶,当然也可作为毕设项目、课程设计、大作业、项目初期立项演示等。 3、如果基础还行,也可在此代码基础上进行修改,以实现其他功能,也可用于毕设、课设、作业等。 下载后请首先打开README.txt文件,仅供学习参考, 切勿用于商业用途。
美国纽约HVAC(暖通空调)数据示例,谷歌地图数据包括:时间戳、名称、类别、地址、描述、开放网站、电话号码、开放时间、更新开放时间、评论计数、评级、主图像、评论、url、纬度、经度、地点id、国家等。 在地理位置服务(LBS)中,谷歌地图数据采集尤其受到关注,因为它提供了关于各种商业实体的详尽信息,这对于消费者和企业都有极大的价值。本篇文章将详细介绍美国纽约地区的HVAC(暖通空调)系统相关数据示例,此示例数据是通过谷歌地图抓取得到的,展示了此技术在商业和消费者领域的应用潜力。 无需外网,无需任何软件抓取谷歌地图数据:wmhuoke.com
2023-04-06-项目笔记-第四百五十五阶段-课前小分享_小分享1.坚持提交gitee 小分享2.作业中提交代码 小分享3.写代码注意代码风格 4.3.1变量的使用 4.4变量的作用域与生命周期 4.4.1局部变量的作用域 4.4.2全局变量的作用域 4.4.2.1全局变量的作用域_1 4.4.2.453局变量的作用域_453- 2025-04-01
1_实验三 扰码、卷积编码及交织.ppt
北京交通大学901软件工程导论必备知识点.pdf
内容概要:本文档总结了 MyBatis 的常见面试题,涵盖了 MyBatis 的基本概念、优缺点、适用场合、SQL 语句编写技巧、分页机制、主键生成、参数传递方式、动态 SQL、缓存机制、关联查询及接口绑定等内容。通过对这些问题的解答,帮助开发者深入理解 MyBatis 的工作原理及其在实际项目中的应用。文档不仅介绍了 MyBatis 的核心功能,还详细解释了其在不同场景下的具体实现方法,如通过 XML 或注解配置 SQL 语句、处理复杂查询、优化性能等。 适合人群:具备一定 Java 开发经验,尤其是对 MyBatis 有初步了解的研发人员,以及希望深入了解 MyBatis 框架原理和最佳实践的开发人员。 使用场景及目标:①理解 MyBatis 的核心概念和工作原理,如 SQL 映射、参数传递、结果映射等;②掌握 MyBatis 在实际项目中的应用技巧,包括 SQL 编写、分页、主键生成、关联查询等;③学习如何通过 XML 和注解配置 SQL 语句,优化 MyBatis 性能,解决实际开发中的问题。 其他说明:文档内容详尽,涵盖面广,适合用于面试准备和技术学习。建议读者在学习过程中结合实际项目进行练习,以更好地掌握 MyBatis 的使用方法和技巧。此外,文档还提供了丰富的示例代码和配置细节,帮助读者加深理解和应用。
《基于YOLOv8的智能电网设备锈蚀评估系统》(包含源码、可视化界面、完整数据集、部署教程)简单部署即可运行。功能完善、操作简单,适合毕设或课程设计
插头模具 CAD图纸.zip
资源内项目源码是来自个人的毕业设计,代码都测试ok,包含源码、数据集、可视化页面和部署说明,可产生核心指标曲线图、混淆矩阵、F1分数曲线、精确率-召回率曲线、验证集预测结果、标签分布图。都是运行成功后才上传资源,毕设答辩评审绝对信服的保底85分以上,放心下载使用,拿来就能用。包含源码、数据集、可视化页面和部署说明一站式服务,拿来就能用的绝对好资源!!! 项目备注 1、该资源内项目代码都经过测试运行成功,功能ok的情况下才上传的,请放心下载使用! 2、本项目适合计算机相关专业(如计科、人工智能、通信工程、自动化、电子信息等)的在校学生、老师或者企业员工下载学习,也适合小白学习进阶,当然也可作为毕设项目、课程设计、大作业、项目初期立项演示等。 3、如果基础还行,也可在此代码基础上进行修改,以实现其他功能,也可用于毕设、课设、作业等。 下载后请首先打开README.txt文件,仅供学习参考, 切勿用于商业用途。
《基于YOLOv8的智慧农业水肥一体化控制系统》(包含源码、可视化界面、完整数据集、部署教程)简单部署即可运行。功能完善、操作简单,适合毕设或课程设计
python爬虫;智能切换策略,反爬检测机制
台区终端电科院送检文档
e235d-main.zip
丁祖昱:疫情对中国房地产市场影响分析及未来展望