作为一名程序员我不忘初心,复习指南
01kafka入门1.1什么是kafka 1.2kafka中的基本概念  1.2.1消息和批次  1.2.2主题和分区  1.2.3生产者和消费者、偏移量、消费者群组  1.2.4Broker和集群  1.2.5保留消息02为什么选择kafka2.1优点 2.2常见场景  2.2.1活动跟踪  2.2.2传递
Stella981 Stella981
3年前
ROS 多个传感器 publish 同一个Topic
梳理一下概念ROSNode之间进行通信所利用的最重要的机制就是消息传递,在ROS中,消息有组织的(其实就是定义Msg格式)放到Topic里进行传递Publisher1.生成信息,通过ROSTopic与其它Node进行通信。2.通常用于处理原始的传感器信息,如相机、编码器等。Subsc
Stella981 Stella981
3年前
RabbitMQ的简单模式快速入门与超时异常的处理方法
本文适合JAVA新人,想了解RabbitMQ又不想去看官网文档的人(英语水看的头疼(◎﹏◎),但建议有能力还是去看官网文档)。消息队列MQ(一)MQ全称为MessageQueue,消息队列是应用程序和应用程序之间的通信方法。先引入一下常见的通讯方案。!(https://oscimg.oschina.net/
Stella981 Stella981
3年前
Kafka 高性能吞吐揭秘
Ahighthroughputdistributedmessagingsystem.\ApacheKafkaKafka作为时下最流行的开源消息系统,被广泛地应用在数据缓冲、异步通信、汇集日志、系统解耦等方面。相比较于RocketMQ等其他常见消息系统,Kafka在保障了大部分功能特性的同时,还提供了超一流的读写性能。本文将针对K
Wesley13 Wesley13
3年前
MySQL服务器错误代码和消息
服务器错误信息来自下述源文件:·错误消息信息列在share/errmsg.txt文件中。“%d”和“%s”分别代表编号和字符串,显示时,它们将被消息值取代。·错误值列在share/errmsg.txt文件中,用于生成include/mysqld\_error.h和include/mysqld\_ername.hMySQL源文件中
Stella981 Stella981
3年前
Celery简单说明以及在Django中的配置
Celery1.什么是CleleryCelery是一个简单、灵活且可靠的,处理大量消息的分布式系统专注于实时处理的异步任务队列同时也支持任务调度Celery架构Celery的架构由三部分组成,消息中间件(messagebroker),任务执行单元(worker)和任务执行结果存储(taskresu
Wesley13 Wesley13
3年前
activeMQ入门+spring boot整合activeMQ
最近想要学习MOM(消息中间件:MessageOrientedMiddleware),就从比较基础的activeMQ学起,rabbitMQ、zeroMQ、rocketMQ、Kafka等后续再去学习。上面说activeMQ是一种消息中间件,可是为什么要使用activeMQ?在没有使用JMS的时候,很多应用会出现同步通信(客户端发起请求后需要等待服务
Wesley13 Wesley13
3年前
MQ介绍 & 实例
阅读目录定义优秀MQ特点产品比较实例(简单的实战)关于消息队列与分布式的那些事定义:消息队列(MQ)是一种应用程序对应用程序的通信方法,应用程序通过队列进行通信,而不是通过直接调用彼此来通信,队列的使用除去了接收和发送应
Stella981 Stella981
3年前
RabbitMQ 三种方式的TTL
TTL说明RabbitMQ支持三种方式PerQueueMessageTTL(为进入队列的每一条消息设置一个TTL)QueueTTL(队列的TTL,如果在设置的TTL时间内,没有消费者连接,没有消息发送,RabbitMQ会默认其是将要抛弃不用的,会考虑在TTL到期后删除掉该队列)PerM
Wesley13 Wesley13
3年前
Java Socket基本例子——使用最原始方法
使用最原始的java.net.ServerSocket和java.net.Socket进行socket通信。实现的效果为:客户端向服务端发送消息、服务端向客户端发送消息、保留统计客户端的信息列表、剔除已经断开的客户端等。本文所有代码均可在https://gitee.com/songxinqiang/JavaSocketDemo(https://git