純手寫SpringMVC框架,用註解實現springmvc過程
閒話不多說,直接上程式碼!
1、第一步,首先搭建如下架構,其中,annotation中放置自己編寫的註解,主要包括service controller qualifier RequestMapping
第二步:完成對應的annotation:
-
package com.chaoyue.annotation; import java.lang.annotation.Documented; import java.lang.annotation.ElementType; import java.lang.annotation.Retention; import java.lang.annotation.RetentionPolicy; import java.lang.annotation.Target; /** * Controller註解 * @author 超越 * @Date 2016年11月29日,上午10:37:30 * @motto 人在一起叫聚會,心在一起叫團隊 * @Version 1.0 */ @Target({ ElementType.TYPE }) @Retention(RetentionPolicy.RUNTIME) @Documented public @interface Controller { String value() default ""; } package com.chaoyue.annotation; import java.lang.annotation.Documented; import java.lang.annotation.ElementType; import java.lang.annotation.Retention; import java.lang.annotation.RetentionPolicy; import java.lang.annotation.Target; /** * Quatifier註解 * @author 超越 * @Date 2016年11月29日,上午10:47:52 * @motto 人在一起叫聚會,心在一起叫團隊 * @Version 1.0 */ @Target({ ElementType.FIELD }) // 代表註解的註解 @Retention(RetentionPolicy.RUNTIME) @Documented public @interface Quatifier { String value() default ""; } package com.chaoyue.annotation; import java.lang.annotation.Documented; import java.lang.annotation.ElementType; import java.lang.annotation.Retention; import java.lang.annotation.RetentionPolicy; import java.lang.annotation.Target; /** * RequestMapping註解 * @author 超越 * @Date 2016年11月29日,上午10:39:32 * @motto 人在一起叫聚會,心在一起叫團隊 * @Version 1.0 */ @Target({ ElementType.METHOD }) // 在方法上的註解 @Retention(RetentionPolicy.RUNTIME) @Documented public @interface RequestMapping { String value() default ""; }
-
package com.chaoyue.annotation; import java.lang.annotation.Documented; import java.lang.annotation.ElementType; import java.lang.annotation.Retention; import java.lang.annotation.RetentionPolicy; import java.lang.annotation.Target; /** * 註解Service * @author 超越 * @Date 2016年11月29日,上午10:49:47 * @motto 人在一起叫聚會,心在一起叫團隊 * @Version 1.0 */ @Target({ ElementType.TYPE }) @Retention(RetentionPolicy.RUNTIME) @Documented public @interface Service { String value() default ""; }
2、第二步:編寫對應的servlet類,記得勾選init()方法,用來進行相應的例項化和註解反轉控制。
① 進行包掃描,就是初始化的時候先將整個專案中的包進行掃描,掃描各個檔案分別存起來。
scanPackage("com.chaoyue");//自己的專案,測試用的 所以 掃描包函式的地址寫死了
存在List<String> packageNames=new ArrayList<String>();其中都是這樣:com.chaoyue.annotation.Controller.class,com.chaoyue.annotation.Quatifier.class, com.chaoyue.annotation.RequestMapping.class,有.class字尾。
②過濾和例項化 :由於已經將所有的檔案都存在了packageNames中了,那麼我們必須將對應的Controller例項化才可以進行相應函式呼叫,然後其中的所有檔案並不一定都是對應的controller檔案,所以要進行相應的過濾和處理
filterAndInstance();
過濾後的結果儲存在: Map<String,Object> instanceMap=new HashMap<String,Object>();
其中 String是註解的value, Object是所對應類的例項
③建立一個對映關係(地址對映,不同的地址對映到不同的方法):
handerMap();
結果: Map<String,Object> handerMap=new HashMap<String,Object>();
例項:
④ 反轉控制,根據註解,把service中的注入到controller中的service;
歡迎留言討論,帶著謙虛的心一起學習!也可以進我私人群一起交流學習!
void ioc() package com.chaoyue.servlet; import java.io.File; import java.io.IOException; import java.lang.reflect.Field; import java.lang.reflect.InvocationTargetException; import java.lang.reflect.Method; import java.net.URL; import java.util.ArrayList; import java.util.HashMap; import java.util.List; import java.util.Map; import javax.servlet.ServletConfig; import javax.servlet.ServletException; import javax.servlet.annotation.WebServlet; import javax.servlet.http.HttpServlet; import javax.servlet.http.HttpServletRequest; import javax.servlet.http.HttpServletResponse; import com.chaoyue.annotation.Controller; import com.chaoyue.annotation.Quatifier; import com.chaoyue.annotation.RequestMapping; import com.chaoyue.annotation.Service; import com.chaoyue.controller.SpringmvcController; @WebServlet("/DispatcherServlet") public class DispatcherServlet extends HttpServlet { private static final long serialVersionUID = 1L; List<String> packageNames = new ArrayList<String>(); // 所有類的例項,key是註解的value,value是所有類的例項 Map<String, Object> instanceMap = new HashMap<String, Object>(); Map<String, Object> handerMap = new HashMap<String, Object>(); public DispatcherServlet() { super(); } public void init(ServletConfig config) throws ServletException { // 包掃描,獲取包中的檔案 scanPackage("com.chaoyue"); try { filterAndInstance(); } catch (Exception e) { e.printStackTrace(); } // 建立對映關係 handerMap(); // 實現注入 ioc(); } private void filterAndInstance() throws Exception { if (packageNames.size() <= 0) { return; } for (String className : packageNames) { Class<?> cName = Class.forName(className.replace(".class", "").trim()); if (cName.isAnnotationPresent(Controller.class)) { Object instance = cName.newInstance(); Controller controller = (Controller) cName.getAnnotation(Controller.class); String key = controller.value(); instanceMap.put(key, instance); } else if (cName.isAnnotationPresent(Service.class)) { Object instance = cName.newInstance(); Service service = (Service) cName.getAnnotation(Service.class); String key = service.value(); instanceMap.put(key, instance); } else { continue; } } } private void ioc() { if (instanceMap.isEmpty()) return; for (Map.Entry<String, Object> entry : instanceMap.entrySet()) { // 拿到裡面的所有屬性 Field fields[] = entry.getValue().getClass().getDeclaredFields(); for (Field field : fields) { field.setAccessible(true);// 可訪問私有屬性 if (field.isAnnotationPresent(Quatifier.class)); Quatifier quatifier = field.getAnnotation(Quatifier.class); String value = quatifier.value(); field.setAccessible(true); try { field.set(entry.getValue(), instanceMap.get(value)); } catch (IllegalArgumentException e) { e.printStackTrace(); } catch (IllegalAccessException e) { e.printStackTrace(); } } } } /** * 掃描包下的所有檔案 * * @param Package */ private void scanPackage(String Package) { URL url = this.getClass().getClassLoader().getResource("/" + replaceTo(Package));// 將所有的.轉義獲取對應的路徑 String pathFile = url.getFile(); File file = new File(pathFile); String fileList[] = file.list(); for (String path : fileList) { File eachFile = new File(pathFile + path); if (eachFile.isDirectory()) { scanPackage(Package + eachFile.getName()); } else { packageNames.add(Package + "." + eachFile.getName()); } } } /** * 建立對映關係 */ private void handerMap() { if (instanceMap.size() <= 0) return; for (Map.Entry<String, Object> entry : instanceMap.entrySet()) { if (entry.getValue().getClass().isAnnotationPresent(Controller.class)) { Controller controller = (Controller) entry.getValue().getClass().getAnnotation(Controller.class); String ctvalue = controller.value(); Method[] methods = entry.getValue().getClass().getMethods(); for (Method method : methods) { if (method.isAnnotationPresent(RequestMapping.class)) { RequestMapping rm = (RequestMapping) method.getAnnotation(RequestMapping.class); String rmvalue = rm.value(); handerMap.put("/" + ctvalue + "/" + rmvalue, method); } else { continue; } } } else { continue; } } } private String replaceTo(String path) { return path.replaceAll("\\.", "/"); } @Override protected void doGet(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException { this.doGet(req, resp); } @Override protected void doPost(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException { String url = req.getRequestURI(); String context = req.getContextPath(); String path = url.replace(context, ""); Method method = (Method) handerMap.get(path); SpringmvcController controller = (SpringmvcController) instanceMap.get(path.split("/")[1]); try { method.invoke(controller, new Object[] { req, resp, null }); } catch (IllegalAccessException e) { e.printStackTrace(); } catch (IllegalArgumentException e) { e.printStackTrace(); } catch (InvocationTargetException e) { e.printStackTrace(); } } }
package com.chaoyue.controller; import javax.servlet.http.HttpServletRequest; import javax.servlet.http.HttpServletResponse; import com.chaoyue.annotation.Controller; import com.chaoyue.annotation.Quatifier; import com.chaoyue.annotation.RequestMapping; import com.chaoyue.service.impl.MyService; import com.chaoyue.service.impl.SpringmvcServiceImpl; @Controller("chaoyue") public class SpringmvcController { @Quatifier("MyServiceImpl") MyService myService; @Quatifier("SpringmvcServiceImpl") SpringmvcServiceImpl smService; @RequestMapping("insert") public String insert(HttpServletRequest request, HttpServletResponse response, String param) { myService.insert(null); smService.insert(null); return null; } @RequestMapping("delete") public String delete(HttpServletRequest request, HttpServletResponse response, String param) { myService.delete(null); smService.delete(null); return null; } @RequestMapping("update") public String update(HttpServletRequest request, HttpServletResponse response, String param) { myService.update(null); smService.update(null); return null; } @RequestMapping("select") public String select(HttpServletRequest request, HttpServletResponse response, String param) { myService.select(null); smService.select(null); return null; } }
package com.chaoyue.service.impl; import java.util.Map; public interface MyService { int insert(Map map); int delete(Map map); int update(Map map); int select(Map map); } package com.chaoyue.service.impl; import java.util.Map; import com.chaoyue.annotation.Service; @Service("MyServiceImpl") public class MyServiceImpl implements MyService { @Override public int insert(Map map) { System.out.println("MyServiceImpl:" + "insert"); return 0; } @Override public int delete(Map map) { System.out.println("MyServiceImpl:" + "delete"); return 0; } @Override public int update(Map map) { System.out.println("MyServiceImpl:" + "update"); return 0; } @Override public int select(Map map) { System.out.println("MyServiceImpl:" + "select"); return 0; } }
package com.chaoyue.service.impl; import java.util.Map; public interface SpringmvcService { int insert(Map map); int delete(Map map); int update(Map map); int select(Map map); } package com.chaoyue.service.impl; import java.util.Map; public class SpringmvcServiceImpl implements SpringmvcService { @Override public int insert(Map map) { System.out.println("SpringmvcServiceImpl:" + "insert"); return 0; } @Override public int delete(Map map) { System.out.println("SpringmvcServiceImpl:" + "delete"); return 0; } @Override public int update(Map map) { System.out.println("SpringmvcServiceImpl:" + "update"); return 0; } @Override public int select(Map map) { System.out.println("SpringmvcServiceImpl:" + "select"); return 0; } }
歡迎留言討論,帶著謙虛的心一起學習!也可以進我私人群一起交流學習
歡迎加入QQ群架構華山論劍:836442475【點選進入】(大牛聚集地)一起交流學習探討!
我們提供免費的架構資料 以及免費的解答
不懂得問題都可以來問我們老師,之後還會有職業生涯規劃,以及面試指導
我們每天晚上八點也有公開課免費學習:
10年架構師分享經驗,Dubbo、Redis、Netty、zookeeper、Spring cloud、分散式、高併發等