贵阳网站建设企业,竞价排名推广,建设微信网站制作,宁波seo在线优化公司kafka官网
线程和线程之间的数据交互
在jvm里不同的线程有自己的栈内存#xff0c;但彼此之间交互可以在共享的内存中进行#xff0c;即堆内存#xff0c;堆内存会将这些消息放到队列中#xff0c;具体实现jvm见#xff0c;栈内存各自维护#xff0c;堆内存大家共享
进…kafka官网
线程和线程之间的数据交互
在jvm里不同的线程有自己的栈内存但彼此之间交互可以在共享的内存中进行即堆内存堆内存会将这些消息放到队列中具体实现jvm见栈内存各自维护堆内存大家共享
进程和进程之间的数据交互
不同的进程在服务器上启动的时候中间通过socket和websocket进行交互。 可能会产生的问题
①产生和消费的速度不对等内存/磁盘作为稀有资源会不够用从而产生消息积压的问题可能通过文件存储的方式解决
②要对消息进行处理可能一条消息发给多个进程也可能一条消息切割为多部分被多个进程消费此时就需要一个中间件进行消息的缓冲处理称为消息中间件。
③使用消息中间件也可避免生产者和消费者的直连降低系统的耦合性提高可用性和可拓展性
MQ的简介 Java中消息产生发送到MQ软件中发送消息的被称为Producer(消息提供者)接收消息的被称为Consumer(消息消费者)MQ软件中一般用队列处理消息消息一般包含消息头、消息属性、消息主题内容。
P2P模型 Publish-Subscribe相当于是一对一一条消息一个人发送只能被一个人接收。 PS模型
即是消息的发布和订阅模型 kafka借鉴了JMS模型但不完全遵循所以虽然是消息中间件但不同于RabbitMQ、ActiveMQ、RocketMQ命名中带Message Queuekafka中的消息message一般称之为recordJMS Provider一般称之为Kafka Broker保证消费顺序的索引称之为偏移量offset kafka的基本组件app调用kafka的producer和consumer进行消息的传递和读取其中kafka自身是通过broker代理进行这些消息的处理 broker中的消息想要进行有序处理通过偏移量实现也就是offset。
