生產者：
<?xml version="1.0" encoding="utf-8"?>
消費者：
<?xml version="1.0" encoding="utf-8"?>
生產者傳送訊息**：
首先注入：
@autowired
private kafkatemplatekafkatemplate;
之後進行傳送：
listenablefuture> result = kafkatemplate.send(topic, key, valuestring);消費端：
/**
* kafka消費
* created by liuhuichao on 2017/5/12.
*/public class kafkaconsumerserver implements messagelistener
}
除了整合kafka,熟悉spring的同志們，可能還用spring整合過redis,hbase這些東西，可以完全放心把連線什麼的都交給spring,自己只關注該關注的東西。
ps:
使用spring進行註解開發
使用spring進行註解開發，我們首先需要在spring的配置檔案中，新增掃瞄。也就是掃瞄包中，那個類有註解。包就是你想要掃瞄的那個包。1.component取代 component id 取代 2.web開發，提供3個 component註解衍生註解 功能一樣 取代 repository dao層...
在Spring中使用Quartz進行任務排程 1
概述 各種企業應用幾乎都會碰到任務排程的需求，就拿論壇來說 每隔半個小時生成精華文章的rss檔案，每天凌晨統計論壇使用者的積分排名，每隔30分鐘執行鎖定使用者解鎖任務。對於乙個典型的mis系統來說，在每月1號凌晨統計上個月各部門的業務資料生成月報表，每半個小時查詢使用者是否已經有快到期的待處理業務 ...
使用spring的aop進行許可權攔截
乙個ssi的專案 springmvc mybatis 需要加上許可權驗證 非資料許可權 考慮使用aop來實現。大致思路是使用自定義註解，在需要許可權控制的方法前 controller層 使用註解定義方法所需的許可權，然後使用aop攔截訪問的方法，在執行目標物件前通過反射取得目標物件所需的許可權，然後...