亚游,我不知道她当年出于什么原因选择研究这样一个课题。我也难以想象是什么力量支撑着她研究下去。当她翻阅一篇篇文献、报告、日记、记录稿,她心中又是何等的悲愤?何等的震撼?我为什么这么说呢?请看书中原段:

“‘山寨’并不可怕,可怕的是‘山寨’背后所隐藏的本质。无论是自主研发企业还是那些靠‘山寨’起家的企业,它们所追求的都是利益。在车型极其相似的情况下,‘山寨’企业所生产的车型售价会更低,为了在‘山寨’出的车型中获得利益,他们会在生产过程中进一步压缩成本。而在压缩成本过程中所带来的安全隐患恐怕要由消费者来承担,所以我们的自主企业应该更多地进行自主研发,而尽量避免‘山寨’。”汽车行业评论员凌然如是说。今年开什么店好在一起故意杀人案件中,兄弟二人因讨要工资杀害两名男子、重伤一名女子。二人被抓后,一致说持刀行凶的是弟弟,哥哥没有参与,这让警方对二人的定性产生了分歧。通过同步介入,检察官发现,案发现场还有一名6岁女孩,而警方并没有对其取证,理由是年纪太小不宜取证。检察官当即提出,这名小女孩是最为关键的目击证人,必须采集她的证词,为了保护小女孩的权益,检察官建议在其监护人的陪同下进行询问。最终,小女孩的证词证明两名嫌疑人所说确实是事实,对案件定罪量刑起到关键作用。

发布于 2018-03-23 20:57:36 | 171 次阅读 | 评论: 0 | 来源: 网友投递

这里有新鲜出炉的精品教程,程序狗速度看过来!

Spring Boot

Spring Boot 项目旨在简化创建产品级的 Spring 应用和服务。你可通过它来选择不同的 Spring 平台。可创建独立的 Java 应用和 Web 应用,同时提供了命令行工具来允许 'spring scripts'.


本篇文章主要介绍了在springboot中对kafka进行读写的示例代码,小编觉得挺不错的,现在分享给大家,也给大家做个参考。一起跟随小编过来看看吧

springboot对kafka的client很好的实现了集成,使用非常方便,本文也实现了一个在springboot中实现操作kafka的demo。

1.POM配置

只需要在dependencies中增加 spring-kafka的配置即可。完整效果如下:


<parent>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-parent</artifactId>
    <version>1.5.4.RELEASE</version>
  </parent>

  <properties>
    <java.version>1.8</java.version>
     <spring-kafka.version>1.2.2.RELEASE</spring-kafka.version>
    <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
  </properties>

  <dependencies>
    <dependency>
      <groupId>org.springframework.boot</groupId>
      <artifactId>spring-boot-starter-web</artifactId>
    </dependency>
    <dependency>
      <groupId>org.springframework.boot</groupId>
      <artifactId>spring-boot-starter</artifactId>
    </dependency>
    <dependency>
      <groupId>org.springframework.boot</groupId>
      <artifactId>spring-boot-starter-test</artifactId>
      <scope>test</scope>
    </dependency>
    <dependency>
      <groupId>org.springframework.boot</groupId>
      <artifactId>spring-boot-starter-aop</artifactId>
    </dependency>
   <!-- spring-kafka -->
      <dependency>
      <groupId>org.springframework.kafka</groupId>
      <artifactId>spring-kafka</artifactId>
      <version>${spring-kafka.version}</version>
      </dependency>
      <dependency>
      <groupId>org.springframework.kafka</groupId>
      <artifactId>spring-kafka-test</artifactId>
      <version>${spring-kafka.version}</version>
      <scope>test</scope>
      </dependency>
   </dependencies>

2.生产者

参数配置类,其参数卸载yml文件中,通过@Value注入


package com.dhb.kafka.producer;

import org.apache.kafka.clients.producer.ProducerConfig;
import org.apache.kafka.common.serialization.StringSerializer;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.kafka.core.DefaultKafkaProducerFactory;
import org.springframework.kafka.core.KafkaTemplate;
import org.springframework.kafka.core.ProducerFactory;

import java.util.HashMap;
import java.util.Map;

@Configuration
public class SenderConfig {

  @Value("${kafka.bootstrap-servers}")
  private String bootstrapServers;

  @Bean
  public Map<String,Object> producerConfigs() {
    Map<String,Object> props = new HashMap<>();
    props.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG,this.bootstrapServers);
    props.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, StringSerializer.class);
    props.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG,StringSerializer.class);
    props.put(ProducerConfig.ACKS_CONFIG,"0");
    return props;
  }

  @Bean
  public ProducerFactory<String,String> producerFactory() {
    return new DefaultKafkaProducerFactory<>(producerConfigs());
  }

  @Bean
  public KafkaTemplate<String,String> kafkaTemplate() {
    return new KafkaTemplate<String, String>(producerFactory());
  }

  @Bean
  public Sender sender() {
    return new Sender();
  }
}

消息发送类


package com.dhb.kafka.producer;

import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.kafka.core.KafkaTemplate;

@Slf4j
public class Sender {

  @Autowired
  private KafkaTemplate<String,String> kafkaTemplate;

  public void send(String topic,String payload) {
    log.info("sending payload='{}' to topic='{}'",payload,topic);
    this.kafkaTemplate.send(topic,payload);
  }
}

3.消费者

参数配置类


package com.dhb.kafka.consumer;

import org.apache.kafka.clients.consumer.ConsumerConfig;
import org.apache.kafka.common.serialization.StringDeserializer;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.kafka.annotation.EnableKafka;
import org.springframework.kafka.config.ConcurrentKafkaListenerContainerFactory;
import org.springframework.kafka.core.ConsumerFactory;
import org.springframework.kafka.core.DefaultKafkaConsumerFactory;

import java.util.HashMap;
import java.util.Map;

@Configuration
@EnableKafka
public class ReceiverConfig {

  @Value("${kafka.bootstrap-servers}")
  private String bootstrapServers;

  public Map<String,Object> consumerConfigs() {
    Map<String,Object> props = new HashMap<>();
    props.put(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG,bootstrapServers);
    props.put(ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG, StringDeserializer.class);
    props.put(ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG,StringDeserializer.class);
    props.put(ConsumerConfig.GROUP_ID_CONFIG,"helloword");
    return props;
  }

  @Bean
  public ConsumerFactory<String,String> consumerFactory() {
    return new DefaultKafkaConsumerFactory<>(consumerConfigs());
  }

  @Bean
  public ConcurrentKafkaListenerContainerFactory<String,String> kafkaListenerContainerFactory() {
    ConcurrentKafkaListenerContainerFactory<String,String> factory =
        new ConcurrentKafkaListenerContainerFactory<>();
    factory.setConsumerFactory(consumerFactory());
    return factory;
  }

  @Bean
  public Receiver receiver() {
    return new Receiver();
  }

}

消息接受类


package com.dhb.kafka.consumer;

import lombok.extern.slf4j.Slf4j;
import org.springframework.kafka.annotation.KafkaListener;

import java.util.concurrent.CountDownLatch;

@Slf4j
public class Receiver {

  private CountDownLatch latch = new CountDownLatch(1);

  public CountDownLatch getLatch() {
    return latch;
  }

  @KafkaListener(topics = "${kafka.topic.helloworld}")
  public void receive(String payload) {
    log.info("received payload='{}'",payload);
    latch.countDown();
  }
}

3.web测试类

定义了一个基于http的web测试接口


package com.dhb.kafka.web;

import com.dhb.kafka.producer.Sender;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.RestController;

import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import java.io.IOException;

@RestController
@Slf4j
public class KafkaProducer {

  @Autowired
  Sender sender;

  @RequestMapping(value = "/sender.action", method = RequestMethod.POST)
  public void exec(HttpServletRequest request, HttpServletResponse response,String data) throws IOException{
    this.sender.send("testtopic",data);
    response.setCharacterEncoding("UTF-8");
    response.setContentType("text/json");
    response.getWriter().write("success");
    response.getWriter().flush();
    response.getWriter().close();
  }

}

4.启动类及配置


package com.dhb.kafka;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;

@SpringBootApplication
public class KafkaApplication {


  public static void main(String[] args) {
    SpringApplication.run(KafkaApplication.class,args);

  }
}

application.yml


kafka:
 bootstrap-servers: 192.168.162.239:9092
 topic:
  helloworld: testtopic

程序结构:

包结构

5.读写测试

通过执行KafkaApplication的main方法启动程序。然后打开postman进行测试:


运行后返回success


生产者日志:


消费者日志:


以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持PHPERZ。



相关阅读 :
亚游在springboot中对kafka进行读写的示例代码
在springboot中对kafka进行读写的示例代码
在springboot中对kafka进行读写的示例代码
springboot前后台数据交互的示例代码
springboot+maven快速构建项目的示例代码
springboot+maven快速构建项目的示例代码
springboot+maven快速构建项目的示例代码
SpringBoot配置发送Email的示例代码
SpringBoot配置发送Email的示例代码
SpringBoot配置发送Email的示例代码
详解SpringBoot中实现依赖注入功能
详解SpringBoot缓存的实例代码(EhCache 2.x 篇)
最新网友评论  共有(0)条评论 发布评论 返回顶部

Copyright © 2007-2017 亚游 All Rights Reserved   冀ICP备14009818号  亚游  广告服务
男子向退休领导行贿 被判对有影响力的人行贿罪 趁机搅浑水 美官员为澳大利亚“反华潮”煽风点火 江苏出局两新生代发挥欠佳 袁心玥加盟难掩漏洞 报不满却号称要抽签 大量马拉松报名遭遇滑铁卢 PTA反弹有望延续 亚马逊毛利润猛增444亿元 超五大零售商预期增长总和 俞敏洪Diss今日头条:做教育和流量还是有差别 数说排超元年:网络点击数破7亿 收视率屡创新高 Science专业论文:火星冰川下液态水的雷达证据 天津航空A320客机遭雹击 雷达罩凹陷风挡被击裂(图) 进球gif-申花U23绊倒阿兰送点 高拉特锁定胜局 北京成最激动人心城市 老外感觉“生活在新时代”
美国宣布对朝进行新制裁 因朝鲜籍男子在马被杀害 马克龙计划改革欧元区!民粹主义或成大阻力 国务院机构改革:调整全国社保基金理事会隶属关系 亚洲股市涨跌不一 港股开盘涨1.1% 4个月密集召回200万台产品 松下电器在华发展陷泥潭 堀田由美:《棋魂》拍网剧起初不安 之后反而期待 澳15岁男孩离家出走被找到时只剩残肢 凶手是它 高通终止收购恩智浦 分手费是净利80% 隔壁大火都能闻到焦味 男孩没跑事后都说他做对了 盘前:非农远超预期 美国股指期货小幅攀升 曼城多特冷负 18032期滚存974万二等3注139万 名宿:温格是阿森纳的传奇 但他真应该离开了
室内世锦赛石雨豪跳远第五 非洲女将60米首夺冠 央行出手微信扫码支付要限额 每天花钱最多这个数 林建超:盛世强国来临之际 围棋没有道理不繁荣 孕妇医院做人流险丧命 子宫一角还被切除 脱欧让英国魅力大减 高端房产降价12万欧盟人才外流 黄金联赛重庆半决赛-重庆农商行队大胜晋级 19岁美女惨死自家车房 家人保护案发现场20年 北京冬奥场馆轮廓渐清晰 三大赛区建设全面开启 拆解疫苗产品 “高毛利”逻辑:区间为60%到90% 没钱怎么创业 两万元投资 一万元猪舍建设图片 没钱怎么创业 亚游