最近有不少朋友在询问宝贝鱼(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服务器。支持服_CshBBrain
CshBBrainJS后面将支持 宝贝鱼(CshBBrain和CshBBrainAIO) 服务器集群功能。 CshBBrainJS不仅可以和开源WebSocket服务器项目 宝贝鱼(CshBBrain和CshBBrainAIO)配合使用,还可以与其他WebSocket服务器搭配使用。...
【CshBBrainAIO V4.0.3(宝贝鱼)】是一个基于Java平台的高级I/O(Asynchronous Input/Output,简称AIO)框架,通常用于开发高性能、高并发的网络应用。AIO与传统的IO模型不同,它允许程序在数据准备就绪后才进行实际...
项目工程资源经过严格测试运行并且功能上ok,可实现复现复刻,拿到资料包后可实现复现出一样的项目,本人系统开发经验充足(全栈全领域),有任何使用问题欢迎随时与我联系,我会抽时间努力为您解惑,提供帮助 【资源内容】:包含源码+工程文件+说明等。答辩评审平均分达到96分,放心下载使用!可实现复现;设计报告也可借鉴此项目;该资源内项目代码都经过测试运行,功能ok 【项目价值】:可用在相关项目设计中,皆可应用在项目、毕业设计、课程设计、期末/期中/大作业、工程实训、大创等学科竞赛比赛、初期项目立项、学习/练手等方面,可借鉴此优质项目实现复刻,设计报告也可借鉴此项目,也可基于此项目来扩展开发出更多功能 【提供帮助】:有任何使用上的问题欢迎随时与我联系,抽时间努力解答解惑,提供帮助 【附带帮助】:若还需要相关开发工具、学习资料等,我会提供帮助,提供资料,鼓励学习进步 下载后请首先打开说明文件(如有);整理时不同项目所包含资源内容不同;项目工程可实现复现复刻,如果基础还行,也可在此程序基础上进行修改,以实现其它功能。供开源学习/技术交流/学习参考,勿用于商业用途。质量优质,放心下载使用
内容概要:本文档提供了关于数据分析全面的知识介绍与实战资源链接。首先,在数据分析的基础教程部分讲述了使用Python以及R两种语言来进行实际的数据分析工作所需具备的各项基本技能。其次,进阶教程涵盖从机器学习到深度学习的概念及其Python具体应用场景。接着,在工具有效利用层面介绍了多种热门库与平台的作用特点。在项目实践中,列举了四个实战案例:Titanic幸存者预测、房价预测、社交媒体情感倾向分析以及市场顾客购买模式研究,每个项目都有详细的技术流程指引。另外列出多个外部网站资源供进一步提升学习。 适用人群:本文主要面向有志于从事数据挖掘工作的学生和技术爱好者,同时也可辅助在职人士自我能力进阶。无论是在学术科研还是实际业务需求环境中都值得研读。 使用场景及目标:学习者将能够获取到系统的理论知识体系,熟悉业界主流软件包的功能优势,掌握具体业务问题解决方案路径,提高自身的综合技术素质,从而为个人职业规划增添竞争力。 其他说明:文档里推荐了不少高质量参考资料和实用线上学习社区,能有效补充专业知识空白并促进社交协作交流。
从埃安泰国工厂竣工看中国车企加快海外建厂步伐.pptx
复现改进的L-SHADE差分进化算法求解最优化问题详解:附MATLAB源码与测试函数集,复现改进的L-SHADE差分进化算法求解最优化问题详解:MATLAB源码与测试集全攻略,复现改进的L-SHADE差分进化算法求最优化问题 对配套文献所提出的改进的L-SHADE差分进化算法求解最优化问题的的复现,提供完整MATLAB源代码和测试函数集,到手可运行,运行效果如图2所示。 代码所用测试函数集与文献相同:对CEC2014最优化测试函数集中的全部30个函数进行了测试验证,运行结果与文献一致。 ,复现; 改进的L-SHADE差分进化算法; 最优化问题求解; MATLAB源代码; 测试函数集; CEC2014最优化测试函数集,复现改进L-SHADE算法:最优化问题的MATLAB求解与验证
可选择参考电压与输出电压 可选择电阻精度以及输出电压误差值
西门子博途三部十层电梯程序案例解析:基于Wincc RT Professional V14及更高版本的应用探索,西门子博途三部十层电梯程序案例解析:基于Wincc RT Professional画面与V14及以上版本技术参考,西门子1200博途三部十层电梯程序案例,加Wincc RT Professional画面三部十层电梯程序,版本V14及以上。 程序仅限于参考资料使用。 ,西门子;1200博途;三部十层电梯程序案例;Wincc RT Professional;V14以上程序版本。,西门子V14+博途三部十层电梯程序案例:Wincc RT Pro专业画面技术解析
2023政务大数据解决方案.pptx
项目工程资源经过严格测试运行并且功能上ok,可实现复现复刻,拿到资料包后可实现复现出一样的项目,本人系统开发经验充足(全栈全领域),有任何使用问题欢迎随时与我联系,我会抽时间努力为您解惑,提供帮助 【资源内容】:包含源码+工程文件+说明等。答辩评审平均分达到96分,放心下载使用!可实现复现;设计报告也可借鉴此项目;该资源内项目代码都经过测试运行;功能ok 【项目价值】:可用在相关项目设计中,皆可应用在项目、毕业设计、课程设计、期末/期中/大作业、工程实训、大创等学科竞赛比赛、初期项目立项、学习/练手等方面,可借鉴此优质项目实现复刻,设计报告也可借鉴此项目,也可基于此项目来扩展开发出更多功能 【提供帮助】:有任何使用上的问题欢迎随时与我联系,抽时间努力解答解惑,提供帮助 【附带帮助】:若还需要相关开发工具、学习资料等,我会提供帮助,提供资料,鼓励学习进步 下载后请首先打开说明文件(如有);整理时不同项目所包含资源内容不同;项目工程可实现复现复刻,如果基础还行,也可在此程序基础上进行修改,以实现其它功能。供开源学习/技术交流/学习参考,勿用于商业用途。质量优质,放心下载使用
内容概要:本文介绍了基于Java的学业跟踪评价系统的详细设计与实现,涵盖系统的多维度数据整合与评价、智能化学习建议、数据可视化和实时反馈等方面。系统通过收集课堂表现、作业成绩、考试成绩等多源数据,对学生的学业表现进行全面跟踪和评价,提供可视化反馈以及个性化的学习建议,促进家校互动,助力学生全面素质提升和发展。 适合人群:具备一定Java编程经验的研究者和开发者,特别是从事教育信息化领域的从业人员和技术爱好者。 使用场景及目标:该系统主要用于K12教育阶段、高等教育以及其他涉及教育培训的场景。其目的是提高教育管理效率、推进教育数字化转型和个人化教育实施。 其他说明:该文档详细介绍了系统的设计思路、功能模块和技术细节,并提供了完整的程序代码以及GUI设计说明。对于希望深入了解或实际部署学业跟踪评价系统的机构非常有参考价值。文中强调技术创新与实践经验相结合,突出了实用性和前瞻性特点。
项目工程资源经过严格测试运行并且功能上ok,可实现复现复刻,拿到资料包后可实现复现出一样的项目,本人系统开发经验充足(全栈全领域),有任何使用问题欢迎随时与我联系,我会抽时间努力为您解惑,提供帮助 【资源内容】:包含源码+工程文件+说明等。答辩评审平均分达到96分,放心下载使用!可实现复现;设计报告也可借鉴此项目;该资源内项目代码都经过测试运行;功能ok 【项目价值】:可用在相关项目设计中,皆可应用在项目、毕业设计、课程设计、期末/期中/大作业、工程实训、大创等学科竞赛比赛、初期项目立项、学习/练手等方面,可借鉴此优质项目实现复刻,设计报告也可借鉴此项目,也可基于此项目来扩展开发出更多功能 【提供帮助】:有任何使用上的问题欢迎随时与我联系,抽时间努力解答解惑,提供帮助 【附带帮助】:若还需要相关开发工具、学习资料等,我会提供帮助,提供资料,鼓励学习进步 下载后请首先打开说明文件(如有);整理时不同项目所包含资源内容不同;项目工程可实现复现复刻,如果基础还行,也可在此程序基础上进行修改,以实现其它功能。供开源学习/技术交流/学习参考,勿用于商业用途。质量优质,放心下载使用
erlang安装包,rabbmit安装环境
linux 下的oracle数据库的开机启动脚本,将里面的/home/oracle/app/oracle/product/11.2.0/dbhome_1 都改成你的oracle数据库的路径。在root用户下chmod +x 添加执行权限,然后./oracle_setup.sh 执行即可。
基于目标级联分析法的多微网主动配电系统自治优化经济调度算法实现与初级应用,基于目标级联分析法的多微网主动配电系统自治优化经济调度算法实践:初级拉格朗日算法应用,GAMS代码:基于目标级联分析法的多微网主动配电系统自治优化经济调度 该代码并非完全复现该文献,而是参照文献 《基于目标级联分析法的多微网主动配电系统自治优化经济调度》 的目标级联分析法(ATC)的算法部分,采用初级的拉格朗日算法,主网与配网部分模型较为简化。 代码结构完整,注释详细,可读性较强,可以在此基础上进行修改或者移植。 适用于初学者学习ATC模型 ,GAMS代码;目标级联分析法(ATC);微网主动配电系统;自治优化经济调度;拉格朗日算法;主网与配网模型简化;代码结构完整;注释详细;可读性强;初学者学习ATC模型。,基于ATC算法的GAMS多微网经济调度优化代码:简化版学习指南
基于ISODATA改进算法的负荷场景曲线聚类——适用于风光场景生成的高效算法创新,基于ISODATA改进算法的负荷场景曲线聚类(适用于风光场景生成,包含K-means等多种聚类方法与效果评价),基于ISODATA改进算法的负荷场景曲线聚类(适用于风光场景生成) 摘要:代码主要做的是一种基于改进ISODATA算法的负荷场景曲线聚类,代码中,主要做了四种聚类算法,包括基础的K-means算法、ISODATA算法、L-ISODATA算法以及K-L-ISODATA算法,并且包含了对聚类场景以及聚类效果的评价,通过DBI的计算值综合对比评价不同方法的聚类效果,程序实现效果非常好,适合对于算法创新有需求的人,且也包含基础的k-means算法,用来学习也非常棒 另外,此代码同样适用于风光场景生成,自己准备好风光场景数据即可 代码非常精品,有部分注释; ,核心关键词: 1. 基于ISODATA改进算法 2. 负荷场景曲线聚类 3. K-means算法 4. 聚类场景评价 5. 聚类效果评价 6. DBI计算值 7. 算法创新需求 8. 风光场景生成 以上关键词用分号分隔为: 1. 基于ISO
xPack qemu arm 是一款高性能且跨平台的 ARM 架构虚拟机
莫理莉+AI+为新型能源系统赋能-技术与建筑建筑供配电论坛琶洲.pptx