java中间件_uncode-mq 基于netty的轻量级java消息中间件
功能特点
- 消息存储速度非常快速。
- 使用简单方便,目前只支持topic方式。
- 依赖java环境。
说明:目前只在部分项目中使用,欢迎学习交流。
模块架构
说明:集群由多个Group组成一个队列,每个Group由Master和Salve两个Broker组成,整体无中心架构。
部署
1 下载文件解压umq-*.tar.gz到任意目录。
2 配置信息
在conf/config.properties文件中填写相关信息。
mq.host=192.168.1.43 #本机ipmq.port=9000 #端口mq.replica.host=192.168.7.131 #本机作为备机的主机ipmq.replica.fetch.size=100 #每次备份时同步的数据条数,默认30mq.replica.fetch.interval=2 #备份同步时间间隔,默认2秒mq.log.dir=./data #数据存储目录,默认data,不建议修改mq.data.persistence.interval=2 #数据持久化的时间间隔,默认2秒mq.enable.zookeeper=true #是否使用zk,集群环境下必须使用mq.zk.connect=192.168.1.14:2181 #zk地址mq.zk.username=admin #zk用户名mq.zk.password=password #zk密码mq.zk.connectiontimeout.ms=6000 #zk连接超时时间mq.zk.sessiontimeout.ms=6000 #zk连接session过期时间mq.zk.data.persistence.interval=6000 #zk数据同步时间,默认6秒mq.active.broker.url= #支持转发到activemqmq.enable.consumer=false #是否启用consumer
3 启动执行startup.sh,停止执行shutdown.sh,查看运行状态执行status.sh,查看主题信息执行info.sh,清除zk相关信息执行zkclear.sh。
4 目录
umq/conf 配置 umq/data 数据存储 umq/logs 日志 umq/lib 依赖jar
生产者
生产者为单例,必须最少执行一次connect操作,连接成功后不会重复connect。
String cfg = "file:/gitlib/uncode-mq/conf/config.properties";Producer.getInstance().connect(cfg);for(int i=0;i<10000;i++){List list = new ArrayList();Topic topic = new Topic();topic.setTopic("umq");topic.addContent("umq作者juny=>"+i);list.add(topic);Producer.getInstance().send(list);}或Properties config = new Properties();config.setProperty("mq.port
java中间件_uncode-mq 基于netty的轻量级java消息中间件相关推荐
- java transferto_小六六学Netty系列之Java 零拷贝
前言 文本已收录至我的GitHub仓库,欢迎Star:https://github.com/bin392328206/six-finger种一棵树最好的时间是十年前,其次是现在 我知道很多人不玩qq了 ...
- java 快递项目_基于SpringBoot开发的Java快递代拿系统
该项目基于 [基于SSM开发的Java快递代拿系统] 项目全面升级,使用当前最为流行的 SpringBoot 框架,相关技术栈全面更新!是您深入学习 SpringBoot 开发的最佳实践! 相关技术栈 ...
- java 复杂网络分析_基于复杂网络的Java程序分析工具设计与实现思路浅谈
基于复杂网络的Java程序分析工具设计与 实现思路浅谈 摘要:近年来,随着科学技术的进步,计算机技术发展速度的加快,使得软件价值也逐步提高,不管是软件系统的应用领域,还是其规模均获得了相应的扩大,且软 ...
- 基于netty访问WebSocket(java的websocket客户端)(访问远程ws协议)
1. 首先创建mvn项目 2. pom中导入jar包 <dependency><groupId>io.netty</groupId><artifactId&g ...
- java商城管理系统_基于SSM框架的JAVA商场管理系统
每天记录学习,每天会有好心情.*^_^* 今天记录的项目是商场管理系统,这个项目是这么回事:随着人们对手机的需求日益增多,手机卖场的规模也随之扩大.众多手机卖场为了能够高效的运作,获得更大的收益,逐步 ...
- JVM之Java内存模型(基于《深入理解Java虚拟机》之第12章Java内存模型与线程)(上)
多任务处理为什么在OS中几乎是一项必备的功能? sadsa sadsa①.计算机的运算能力强大了,但其运算速度与它的存储和 通信子系统的速度 差距太大了,不匹配,大量的时间都花费在磁盘I/O.网络通信 ...
- java axis2 开发_基于Apache axis2开发Java Web服务
1.安装配置axis2环境 下载好后把axis2-1.4.1-war目录下面的axis2.war发布到tomcat的webapps中. 发布好,访问:http://localhost:8079/axi ...
- JAVA就诊叫号_基于B/S的JAVA门诊就诊系统
每天记录学习,每天会有好心情.*^_^* 今日思考,完成一个门诊就诊系统的设计与实现项目,需要实现哪些功能? 此类项目常见描述如下: 本文重点介绍了门诊就诊系统的设计与实现,采用C/S的开发模式,使用 ...
- 招聘管理系统软件java源码_基于Spring Boot的java开源招聘源码-铭阳招聘管理系统...
铭阳招聘管理系统 铭阳招聘管理系统,采用流行的框架Spring Boot+mybatis+ehcache开发,实现了权限管理,solr全文搜索引擎,系统具执行效率高.模板自由切换.后台管理功能灵活等诸 ...
最新文章
- 使用Redis分区将数据分割到多个Redis实例
- mysql 连接超时 wait_timeout interactive_timeout 简介
- Pow(x, n)Python解法
- 【一鸣离职,左晖去世】互联网老兵给大家的三个建议
- 专心写即时通讯软件争取CSDN认证专家
- 速打微补丁!这个越权文件读取漏洞影响 Windows OS
- AEAI DP开发统计分析
- 安装kepserver找不到根证书_考完二手车评估师证书却找不到工作,面试官的话让我记忆犹新!...
- 从拉萨骑行到珠峰大本营
- Ubuntu文本编辑器
- 计算机硬件维修的步骤和方法,计算机硬件组装与维护教程
- 上传图片方法到免费服务器
- 视频压缩 I P B 帧 详解
- web前端课程设计(HTML和CSS实现餐饮美食文化网站)静态HTML网页制作
- H3C-WX2510H对接OpenPortal网络准入认证计费系统实现Mac快速认证+Portal认证
- Pytorch简单一览表
- oracle表自动模拟多条数据,Oracle使用虚拟表dual一次插入多条记录
- OpenCV - C++实战(05) — 颜色检测
- Tushare库之Libor拆借利率
- 柴俊理金:量产高位施压原油,黄金颓势静待非农