当前位置: 首页 > news >正文

西安网站建设sxyun百度seo怎么查排名

西安网站建设sxyun,百度seo怎么查排名,现货平台在中国合法吗,如何做网站营销这里写目录标题1.Kafka1.1 Kafka概述1.2 kafka安装和配置1.3 入门案例1.4 kafka生产者详解1.4.1 生产者的参数1.Kafka 1.1 Kafka概述 Kafka 是一个分布式流媒体平台,类似于消息队列或企业消息传递系统。 producer:发布消息的对象称之为主题生产者(Ka…

这里写目录标题

  • 1.Kafka
    • 1.1 Kafka概述
    • 1.2 kafka安装和配置
    • 1.3 入门案例
    • 1.4 kafka生产者详解
      • 1.4.1 生产者的参数

1.Kafka

1.1 Kafka概述

Kafka 是一个分布式流媒体平台,类似于消息队列或企业消息传递系统。
请添加图片描述

  • producer:发布消息的对象称之为主题生产者(Kafka topic producer)
  • topic:Kafka将消息分门别类,每一类的消息称之为一个主题(Topic)
  • consumer:订阅消息并处理发布的消息的对象称之为主题消费者(consumers)
  • broker:已发布的消息保存在一组服务器中,称之为Kafka集群。集群中的每一个服务器都是一个代理(Broker)。 消费者可以订阅一个或多个主题(topic),并从Broker拉数据,从而消费这些已发布的消息。

1.2 kafka安装和配置

Kafka对于zookeeper是强依赖,保存kafka相关的节点数据,所以安装Kafka之前必须先安装zookeeper

一、Docker安装zookeeper
下载镜像:

docker pull zookeeper:3.4.14

创建容器

docker run -d --name zookeeper -p 2181:2181 zookeeper:3.4.14

一、Docker安装kafka
下载镜像:

docker pull wurstmeister/kafka:2.12-2.3.1

创建容器, 此处需要改为自己虚拟机的ip地址

docker run -d --name kafka \
--env KAFKA_ADVERTISED_HOST_NAME=192.168.200.130 \
--env KAFKA_ZOOKEEPER_CONNECT=192.168.200.130:2181 \
--env KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://192.168.200.130:9092 \
--env KAFKA_LISTENERS=PLAINTEXT://0.0.0.0:9092 \
--env KAFKA_HEAP_OPTS="-Xmx256M -Xms256M" \
--net=host wurstmeister/kafka:2.12-2.3.1

1.3 入门案例

实现一个简单的生产 > 消费过程
请添加图片描述
一、引入依赖

<dependency><groupId>org.apache.kafka</groupId><artifactId>kafka-clients</artifactId>
</dependency>

二、生产者发送消息

  1. 连接kafka
  2. 创建生产者对象
  3. 发送信息
  4. 关闭消息通道(必须关闭, 否则消息发送不成功)
package com.heima.kafka.sample;import org.apache.kafka.clients.producer.KafkaProducer;
import org.apache.kafka.clients.producer.ProducerConfig;
import org.apache.kafka.clients.producer.ProducerRecord;import java.util.Properties;/*** 生产者*/
public class ProducerQuickStart {public static void main(String[] args) {//1.kafka的配置信息Properties properties = new Properties();//kafka的连接地址properties.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG,"192.168.200.130:9092");//发送失败,失败的重试次数properties.put(ProducerConfig.RETRIES_CONFIG,5);//消息key的序列化器properties.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG,"org.apache.kafka.common.serialization.StringSerializer");//消息value的序列化器properties.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG,"org.apache.kafka.common.serialization.StringSerializer");//2.生产者对象KafkaProducer<String,String> producer = new KafkaProducer<String, String>(properties);//封装发送的消息ProducerRecord<String,String> record = new ProducerRecord<String, String>("itheima-topic","100001","hello kafka");//3.发送消息producer.send(record);//4.关闭消息通道,必须关闭,否则消息发送不成功producer.close();}}

三、消费者接收消息

package com.heima.kafka.sample;import org.apache.kafka.clients.consumer.ConsumerConfig;
import org.apache.kafka.clients.consumer.ConsumerRecord;
import org.apache.kafka.clients.consumer.ConsumerRecords;
import org.apache.kafka.clients.consumer.KafkaConsumer;import java.time.Duration;
import java.util.Collections;
import java.util.Properties;/*** 消费者*/
public class ConsumerQuickStart {public static void main(String[] args) {//1.添加kafka的配置信息Properties properties = new Properties();//kafka的连接地址properties.put(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG, "192.168.200.130:9092");//消费者组properties.put(ConsumerConfig.GROUP_ID_CONFIG, "group2");//消息的反序列化器properties.put(ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG, "org.apache.kafka.common.serialization.StringDeserializer");properties.put(ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG, "org.apache.kafka.common.serialization.StringDeserializer");//2.消费者对象KafkaConsumer<String, String> consumer = new KafkaConsumer<String, String>(properties);//3.订阅主题consumer.subscribe(Collections.singletonList("itheima-topic"));//当前线程一直处于监听状态while (true) {//4.获取消息ConsumerRecords<String, String> consumerRecords = consumer.poll(Duration.ofMillis(1000));for (ConsumerRecord<String, String> consumerRecord : consumerRecords) {System.out.println(consumerRecord.key());System.out.println(consumerRecord.value());}}}}

总结

  • 生产者发送消息,多个消费者订阅同一个主题,只能有一个消费者收到消息(一对一)
  • 生产者发送消息,多个消费者订阅同一个主题,所有消费者都能收到消息(一对多)

1.4 kafka生产者详解

一、同步发送
  使用send()方法发送,它会返回一个Future对象,调用get()方法进行等待,就可以知道消息是否发送成功

RecordMetadata recordMetadata = producer.send(kvProducerRecord).get();
System.out.println(recordMetadata.offset());

二、异步发送
调用send()方法,并指定一个回调函数,服务器在返回响应时调用函数

//异步消息发送
producer.send(kvProducerRecord, new Callback() {@Overridepublic void onCompletion(RecordMetadata recordMetadata, Exception e) {if(e != null){System.out.println("记录异常信息到日志表中");}System.out.println(recordMetadata.offset());}
});

1.4.1 生产者的参数

一、ack
请添加图片描述
代码的配置方式:

//ack配置  消息确认机制
prop.put(ProducerConfig.ACKS_CONFIG,"all");

在这里插入图片描述


二、retries

http://www.hrbkazy.com/news/20497.html

相关文章:

  • 专业做数据的网站有哪些方面怎么让付费网站免费
  • 如何在百度建立自己的网站公司网站建设费
  • 合肥网站建设推荐 晨飞网络营销策划的十个步骤
  • 怎么做企业网站建设浙江百度推广
  • Vs做的网站调试时如何适应网页seo推广招聘
  • 云南网是什么网站百度学术官网
  • 帝国网站管理系统教程信息流广告接单平台
  • 域名服务器ip查询seoul是哪个城市
  • 网站如何做微信支付宝支付宝支付宝谷歌seo搜索引擎下载
  • 学校门户网站的网站建设方案网站文章优化技巧
  • 甘肃手机版建站系统价格网站seo优化步骤
  • 外包做网站哪家好wix网站制作
  • 常州网站制作公司有哪些互联网营销是做什么的
  • 网站建设如何找客户最近大事件新闻
  • 做网站的感觉朋友圈广告投放价格表
  • 开源企业建站系统哪个好网络营销的原理
  • 巴中住房建设部网站网站查找工具
  • 个人做淘宝客网站要备案吗网络客服
  • 电子商务网站规划与建设论文阿里指数app下载
  • 免费做网络推广的网站可靠吗企业培训课程有哪些
  • 怎么在凡科做自己网站公司网站与推广
  • 个人网站里在哪点击模版在广州做seo找哪家公司
  • 网站ftp深圳seo网站推广方案
  • 全球网站制作深圳网站seo地址
  • dede可以做购物网站吗在线代理浏览网页
  • php网站日历选择日期怎么做网站优化排名怎么做
  • wordpress ghostjs关键词优化排名公司
  • 全国icp备案查询百度seo自动优化
  • 成都免费建网站公司怎样做一个网站
  • 做网站行业怎么样宁波pc营销型网站制作