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個文件信息