搜索结果
查询Tags标签： topic，共有 206条记录-
【ROS学习笔记】4.玩转小海龟——ROS命令行工具
文章目录 1 回顾第一个小海龟程序2 查看系统中的计算图：rqt_graph3 rosnode显示话题列表：rosnode list查看节点信息：rosnode info 4 rostopic显示topic列表：rostopic list手动发布数据给topic 5 rosmsg查看消息数据结构 6 使用服务通信方式：rosservice查看服务列表：…
2022/1/12 23:06:57 人评论 次浏览 -
ruby on rails 添加vote
现在有一个问题，就是说： 我们需要点击topic ，topic上面有一个vote ，点击vote可以加1， 再点击在家1， 再点击加1 ，那么，该如何去做这件事情呢？首先是需要有数据库存储vote的，所以，建立一个model ，，然后建立起来把数据库， 那么，再接下来一步就是吧topic的mode…
2022/1/10 12:33:29 人评论 次浏览 -
ruby on rails 添加vote
现在有一个问题，就是说： 我们需要点击topic ，topic上面有一个vote ，点击vote可以加1， 再点击在家1， 再点击加1 ，那么，该如何去做这件事情呢？首先是需要有数据库存储vote的，所以，建立一个model ，，然后建立起来把数据库， 那么，再接下来一步就是吧topic的mode…
2022/1/10 12:33:29 人评论 次浏览 -
Kafka消息队列
之前也学习过消息队列，但一直没有使用的场景，今天项目中遇到了 kafka 那便有了应用场景1. Kafka Kafka 是一个分布式、支持分区，多副本的基于 zookeeper 的消息队列。使用消息队列，是应用 A 将要处理的信息发送到消息队列然后继续下面的任务，需要该信息的应用 B 从消…
2022/1/9 23:34:17 人评论 次浏览 -
Kafka消息队列
之前也学习过消息队列，但一直没有使用的场景，今天项目中遇到了 kafka 那便有了应用场景1. Kafka Kafka 是一个分布式、支持分区，多副本的基于 zookeeper 的消息队列。使用消息队列，是应用 A 将要处理的信息发送到消息队列然后继续下面的任务，需要该信息的应用 B 从消…
2022/1/9 23:34:17 人评论 次浏览 -
kafka集群搭建
kafka相关术语 Producer: 消息生产者，就是向kafka broker发消息的客户端 Consumer: 消息消费者，向kafka broker取消息的客户端 Consumer Group（简称"CG"）:消费者组 Broker：一台kafka服务器就是一个broker，一个集群由多个broker组成，一个broker可以容纳多…
2022/1/7 6:08:02 人评论 次浏览 -
kafka集群搭建
kafka相关术语 Producer: 消息生产者，就是向kafka broker发消息的客户端 Consumer: 消息消费者，向kafka broker取消息的客户端 Consumer Group（简称"CG"）:消费者组 Broker：一台kafka服务器就是一个broker，一个集群由多个broker组成，一个broker可以容纳多…
2022/1/7 6:08:02 人评论 次浏览 -
RocketMQ实战：生产环境中，java开发基础形考作业题
3.1 RocketMQ基本路由规则Broker在启动时向Nameserver注册存储在该服务器上的路由信息，并每隔30s向Nameserver发送心跳包，并更新路由信息。 Nameserver每隔10s扫描路由表，如果检测到Broker服务宕机，则移除对应的路由信息。 消息生产者每隔30s会从Nameserver重新拉取…
2021/12/29 17:09:25 人评论 次浏览 -
RocketMQ实战：生产环境中，java开发基础形考作业题
3.1 RocketMQ基本路由规则Broker在启动时向Nameserver注册存储在该服务器上的路由信息，并每隔30s向Nameserver发送心跳包，并更新路由信息。 Nameserver每隔10s扫描路由表，如果检测到Broker服务宕机，则移除对应的路由信息。 消息生产者每隔30s会从Nameserver重新拉取…
2021/12/29 17:09:25 人评论 次浏览 -
K8S环境快速部署Kafka(K8S外部可访问)，mysql数据库优化及sql调优
参考文章 本次实战涉及到的K8S、Helm、NFS、StorageClass等前置条件，它们的安装和使用请参考：《kubespray2.11安装kubernetes1.15》 《部署和体验Helm(2.16.1版本)》 《Ubuntu16环境安装和使用NFS》 《K8S使用群晖DS218+的NFS》 《K8S的StorageClass实战(NFS)》 环…
2021/12/24 19:09:25 人评论 次浏览 -
K8S环境快速部署Kafka(K8S外部可访问)，mysql数据库优化及sql调优
参考文章 本次实战涉及到的K8S、Helm、NFS、StorageClass等前置条件，它们的安装和使用请参考：《kubespray2.11安装kubernetes1.15》 《部署和体验Helm(2.16.1版本)》 《Ubuntu16环境安装和使用NFS》 《K8S使用群晖DS218+的NFS》 《K8S的StorageClass实战(NFS)》 环…
2021/12/24 19:09:25 人评论 次浏览 -
kafka学习之-server.properties详细说明
每个kafka broker中配置文件server.properties默认必须配置的属性如下： broker.id=0num.network.threads=2num.io.threads=8socket.send.buffer.bytes=1048576socket.receive.buffer.bytes=1048576socket.request.max.bytes=104857600log.dirs=/tmp/kafka-logsnum.partit…
2021/12/23 23:09:39 人评论 次浏览 -
kafka学习之-server.properties详细说明
每个kafka broker中配置文件server.properties默认必须配置的属性如下： broker.id=0num.network.threads=2num.io.threads=8socket.send.buffer.bytes=1048576socket.receive.buffer.bytes=1048576socket.request.max.bytes=104857600log.dirs=/tmp/kafka-logsnum.partit…
2021/12/23 23:09:39 人评论 次浏览 -
如何使用Python读写Kafka？
这一篇文章里面，我们要使用的一个第三方库叫做kafka-python。大家可以使用pip或者pipenv安装它。下面两种安装方案，任选其一即可python3 -m pip install kafka-python pipenv install kafka-python如下图所示：创建配置文件 由于生产者和消费者都需要连接Kafka，所以我单…
2021/12/20 20:22:06 人评论 次浏览 -
如何使用Python读写Kafka？
这一篇文章里面，我们要使用的一个第三方库叫做kafka-python。大家可以使用pip或者pipenv安装它。下面两种安装方案，任选其一即可python3 -m pip install kafka-python pipenv install kafka-python如下图所示：创建配置文件 由于生产者和消费者都需要连接Kafka，所以我单…
2021/12/20 20:22:06 人评论 次浏览
