spring+Kafka+springmvc Demo-白红宇

一、下载(官网下载:http://kafka.apache.org/downloads.html)

任意下载一个zip解压

二、制作demo示例，spring+springmvc+Kafka

开发前请先安装zookeeper，

1. 启动kafka服务：安装目录下.\bin\windows\kafka-server-start.bat .\config\server.properties

启动zookeeper：进入zk的安装文件夹bin目录下双击zkServer.bat文件（因为kafka的topic需要在zk注册中心注册）

2.创建topic：bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test

3.引入maven依赖，其中引入了多余的依赖，直接从笔者的demo项目中复制过来


        
     
      org.apache.kafka
         
     
      kafka_2.10
         
     
      0.8.2.1
         
             
                  
       
        jmxri
                   
       
        com.sun.jmx
               
              
                  
       
        jms
                   
       
        javax.jms
               
              
                  
       
        jmxtools
                   
       
        com.sun.jdmk
               
          
     
    
        
     
      org.springframework.kafka
         
     
      spring-kafka
         
     
      1.1.1.RELEASE
     
    
        
     
      org.apache.kafka
         
     
      kafka-clients
         
     
      0.9.0.1
     
    复制代码

复制代码


        
     
      org.springframework
         
     
      spring-web
         
     
      4.3.10.RELEASE
     
    
        
     
      org.springframework
         
     
      spring-webmvc
         
     
      4.3.14.RELEASE
     
    
        
     
      org.freemarker
         
     
      freemarker
         
     
      2.3.22
     
    
        
     
      org.springframework
         
     
      spring-context-support
         
     
      4.1.6.RELEASE
     
    
        
     
      com.github.miemiedev
         
     
      mybatis-paginator
         
     
      1.2.15
     
    
        
     
      com.fasterxml.jackson.core
         
     
      jackson-core
         
     
      2.8.9
     
    
        
     
      carhouse-test
         
     
      carhouse-test-api
         
     
      1.0-SNAPSHOT
     
    
        
     
      com.alibaba
         
     
      dubbo
         
     
      2.5.3
         
             
                  
       
        spring
                   
       
        org.springframework
               
          
     
    
        
     
      com.101tec
         
     
      zkclient
         
     
      0.10
     
    
        
     
      org.springframework.amqp
         
     
      spring-rabbit
         
     
      1.7.5.RELEASE
     
    复制代码

复制代码

4.producer配置(kafka-producer.xml)

5.consumer配置(kafka-consumer.xml)

5.在spring-mvc.xml的配置


    
    
    复制代码

6.实际使用

最简单的一条消息发送

@Resourceprivate KafkaTemplate
    
      kafkaTemplate;@RequestMapping(value = "/hello.do")public void hello(){    kafkaTemplate.sendDefault("test it");    }复制代码

消息消费

package mq.kafka;import org.apache.kafka.clients.consumer.ConsumerRecord;import org.springframework.kafka.listener.MessageListener;public class KafkaConsumerListener implements MessageListener
    
      {    public void onMessage(ConsumerRecord
     
       consumerRecord) {        Object o = consumerRecord.value();        System.out.println(String.valueOf(o));    }}复制代码

最后会在控制台输出“test it”

写的有什么不对的，欢迎各位指出。