springMVC+多线程+kafka的 demo基于maven

多次整理精简，得出基于maven 的springmvc 框架搭载 ：多线程（线程池式）和 kafka（集群下生产者消费者）；demo 下载导入改下kafka集群IP地址即可使用。

package com.test;
/*
 * 文件名：HelloSpringController.java 版权：Copyright by zhyl 修改人：Administrator 修改时间：2018年6月26日
 */


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

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.kafka.core.KafkaTemplate;
import org.springframework.kafka.support.SendResult;
import org.springframework.stereotype.Controller;
import org.springframework.util.concurrent.FailureCallback;
import org.springframework.util.concurrent.ListenableFuture;
import org.springframework.util.concurrent.SuccessCallback;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.servlet.ModelAndView;

import com.alibaba.fastjson.JSONobject;


/**
 * 〈一句话功能简述〉 〈功能详细描述〉
 * 
 * @author zhyl
 * @version 2018年6月26日
 * @see HelloSpringController
 * @since
 */

@Controller
public class HelloSpringController
{
    
    @Autowired
    private RuleService ruleService;
    
    String message = “Welcome to Spring MVC!“;
    
    @Autowired
    KafkaTemplate kafkaTemplate;

    @Value（“nwbs-optimizeNetwork-task“）
    private String optimizeTopic;

    @Value（“nwbs-business-task“）
    private String businessTopic;

    public void producer（）
    {
        //模拟参数
        int i = 0;
        Mapject> zh = new HashMapject>（）;
        zh.put（“zhylwwwwww“+i++ i++）;
        zh.put（“zhylaaaaaaa“+i++ i++）;
        JSONobject  params = new JSONobject（zh）;
        
        kafkaTemplate.send（optimizeTopic params.toJSONString（） + “optimizeTopic“）;
        kafkaTemplate.send（businessTopic params.toJSONString（） + “businessTopic“）;
        ListenableFuture> listenableFuture = kafkaTemplate.sendDefault（
            params.toJSONString（））;
        SuccessCallback> successCallback = new SuccessCallback>（）
        {
            @Override
            public void onSuccess（SendResult result）
            {
                System.out.println（“onSuccess“）;
            }
        };
        FailureCallback failureCallback = new FailureCallback（）
        {
            @Override
            public void onFailure（Throwable ex）
            {
                System.out.println（“onFailure“）;
            }
        };
        listenableFuture.addCallback（successCallback failureCallback）;
    }

    @RequestMapping（“/hello“）
    public ModelAndView showMessage（@RequestParam（value = “name“ required = false defaultValue = “Spring“） String name）
    {
        //路过测试
       // ruleService.updateRule（）;
        
        //kafka
        System.out.println（“==============kafaka============“）;
        producer（）;
        
        // 指定视图
        ModelAndView mv = new ModelAndView（“h

 属性            大小     日期    时间   名称
----------- ---------  ---------- -----  ----
     目录           0  2018-06-26 19:42  HelloSpringMVC\
     文件        1560  2018-07-05 11:04  HelloSpringMVC\.classpath
     文件        1223  2018-07-05 11:00  HelloSpringMVC\.project
     目录           0  2018-06-26 19:40  HelloSpringMVC\.settings\
     文件         639  2018-06-26 19:40  HelloSpringMVC\.settings\.jsdtscope
     文件         641  2018-07-05 11:37  HelloSpringMVC\.settings\org.eclipse.core.resources.prefs
     文件         736  2018-07-05 11:02  HelloSpringMVC\.settings\org.eclipse.jdt.core.prefs
     文件          90  2018-06-26 19:40  HelloSpringMVC\.settings\org.eclipse.m2e.core.prefs
     文件         683  2018-07-05 11:04  HelloSpringMVC\.settings\org.eclipse.wst.common.component
     文件         292  2018-07-05 11:02  HelloSpringMVC\.settings\org.eclipse.wst.common.project.facet.core.xml
     文件          49  2018-06-26 19:40  HelloSpringMVC\.settings\org.eclipse.wst.jsdt.ui.superType.container
     文件           6  2018-06-26 19:40  HelloSpringMVC\.settings\org.eclipse.wst.jsdt.ui.superType.name
     文件          50  2018-06-26 19:40  HelloSpringMVC\.settings\org.eclipse.wst.validation.prefs
     文件        2480  2018-07-06 14:52  HelloSpringMVC\pom.xml
     目录           0  2018-06-26 19:42  HelloSpringMVC\src\
     目录           0  2018-06-26 19:42  HelloSpringMVC\src\main\
     目录           0  2018-06-26 19:49  HelloSpringMVC\src\main\java\
     目录           0  2018-07-05 10:23  HelloSpringMVC\src\main\java\com\
     目录           0  2018-06-26 20:08  HelloSpringMVC\src\main\java\com\test\
     文件        3312  2018-07-06 15:12  HelloSpringMVC\src\main\java\com\test\HelloSpringController.java
     文件        1108  2018-06-26 20:46  HelloSpringMVC\src\main\java\com\test\RuleService.java
     文件         841  2018-06-26 20:20  HelloSpringMVC\src\main\java\com\test\StartTaskThread.java
     目录           0  2018-07-05 10:54  HelloSpringMVC\src\main\java\com\zhyl\
     目录           0  2018-07-05 10:50  HelloSpringMVC\src\main\java\com\zhyl\config\
     文件         915  2018-07-05 10:29  HelloSpringMVC\src\main\java\com\zhyl\config\KafkaConsumerListenser.java
     目录           0  2018-07-05 11:15  HelloSpringMVC\src\main\java\com\zhyl\controller\
     文件        2426  2018-07-05 11:48  HelloSpringMVC\src\main\java\com\zhyl\controller\KafkaController.java
     目录           0  2018-07-05 11:15  HelloSpringMVC\src\main\java\com\zhyl\service\
     文件         825  2018-07-05 11:32  HelloSpringMVC\src\main\java\com\zhyl\service\KafkaConsumerSerivceImpl.java
     目录           0  2018-07-05 10:21  HelloSpringMVC\src\main\resources\
     文件        2731  2018-07-06 14:59  HelloSpringMVC\src\main\resources\kafka.properties
............此处省略51个文件信息