|
2013年3月18日
現(xiàn)在做互聯(lián)網產品的團隊都比較小,也可能沒有特別多運維人員。因此特別需要用一些系統(tǒng)或是工具來監(jiān)控服務器或者是服務是否正常。之前比較直接的做法是自己搭建一套開源的監(jiān)控系統(tǒng),現(xiàn)在隨著云服務器的流行,也有越來越多的人用戶會使用云端的監(jiān)控平臺。
從我的經驗來看,云服務器監(jiān)控是有些特別的好處的:
1.自建的監(jiān)控平臺,有一部分問題是沒辦法發(fā)出警報。比如,一般監(jiān)控服務器也會在內部網絡中,如果出現(xiàn)外部網絡問題,監(jiān)控服務是沒辦法通知到相關人員(因為發(fā)郵件或者是發(fā)短信的通路也會出現(xiàn)問題)。
2.自建的監(jiān)控平臺,只能檢測到一個點的訪問情況。阿里云監(jiān)控平臺可以檢測杭州和青島兩個節(jié)點(這是我的帳號看到的),可以比較有效地了解非監(jiān)測點的一個訪問情況。
3.云監(jiān)控平臺都有一套不錯的管理界面,可有效減少部署維護和使用成本。
下面我介紹一下,我使用過的一些云監(jiān)控平臺,并對他們的優(yōu)點和缺點進行比較。
阿里云監(jiān)控
阿里的云服務器在市場中是做的很不錯的,我的很多朋友都購買了阿里的云服務器。以阿里的公司實力,做一款云監(jiān)控的產品應該不會差到哪里去。
優(yōu)點:
1.產品體驗好,進入住界面就能輕而易舉找到你想要的功能。
2.監(jiān)控功能全,包括站點監(jiān)控、服務器監(jiān)控和自定義監(jiān)控。
3.多點監(jiān)控,可以在全國提供幾個點的監(jiān)控。從用戶的角度了解服務是否可用。
4.站點監(jiān)控功能也很全面,包含SMTP、POP3、FTP監(jiān)控。
5.免費,且監(jiān)控站點數(shù)沒限制。
缺點:
1.服務器監(jiān)控和自定義監(jiān)控,要求是云服務器,如果不是云服務器,只能使用站點檢測功能。
360網站服務監(jiān)控
360的個人用戶產品很少使用,但是360的企業(yè)產品還真有不少做的不錯的。說說360監(jiān)控的優(yōu)缺點。
優(yōu)點:
1.提供服務器監(jiān)控。可以監(jiān)控到服務器的磁盤,CPU,內存等情況。
2.UI和告警都設計的不錯。
3.免費。
缺點:
1.需要在服務器上開SNMP協(xié)議。(不過360提供很多腳本工具,可以一鍵安裝)
2.有20臺服務器的限制。(這個基本上夠用,超過20臺服務器,可以購買服務了)
監(jiān)控寶
名字很專一,一看就知道是專業(yè)做監(jiān)控的。
優(yōu)點:
1.專注監(jiān)控,界面設計還算可以。
2.監(jiān)控功能全面,內網采集的方式較多。可以采集數(shù)據(jù)庫數(shù)據(jù)。
缺點:
1.免費用戶,服務器和網站監(jiān)控都有限制,而且數(shù)量極少2臺服務器監(jiān)控,5臺網站監(jiān)控。
作者簡介: qiyadeng(www.qiyadeng.com)對互聯(lián)網技術、運營及市場領域有濃厚的興趣,喜愛思考、閱讀、討論;擅長Java開發(fā)及分布式技術。現(xiàn)專注于互聯(lián)網的創(chuàng)新產品– 老來寶(http://www.laolaibao.com),幫助年輕用戶獲得補充養(yǎng)老金,并提供養(yǎng)老金增值產品。
比較少參加這類大型的會議,進到會場的第一眼,發(fā)現(xiàn)會議室已經全部坐滿,后來主辦方發(fā)現(xiàn)站的人太多了,找來了一些小板凳,我快速找到一個小板凳坐下。坐下開始認真聽,非常開心地聽到廣告時間結束,和我計劃的時間完美一致。
回顧一下我比較關系的幾個主題
基于用戶畫像的大數(shù)據(jù)實例
演講嘉賓是聯(lián)通沃商店的大數(shù)據(jù)技術經理,該大數(shù)據(jù)實例主要是通過聯(lián)通營運商的數(shù)據(jù)和沃商店進行分析,通過繪制用戶畫像的形式,在其他應用場景,如廣告、游戲下載中為用戶推薦用戶喜歡的產品。可以看出來嘉賓技術實例及基礎功是十分不錯,至少是一個碩士畢業(yè)。近些年被大家掛在嘴邊的機器學習算法、推薦算法、語義分析都有部分介紹,實在是接受不過來;比較熟悉的還是我們當初碩士的專業(yè)方向推薦算法,看到了簡單的介紹覺得很親切。不過后來提問環(huán)節(jié)看,現(xiàn)場還是很多高人,有不少是做這個領域的。不過歸根是國有企業(yè)和類似研究機構,是否能產生非常大的價值,我表示懷疑,不過這些算法一羅列,對經費的分配還是很有好處的。
電商系統(tǒng)的心得分享
這又是一個國有企業(yè),號稱是線上賣大力丸的人(國藥1健康)。從技術成長為總經理,有很多心得體會。感覺和我有那么一點像,有一些體會也迫不及待的分析給這些年輕的IT從業(yè)者,為人嚴肅,總是會把困難估計的充分一點(估計年輕也沒少教學費)。演講中說了構建系統(tǒng)中的四個原則
權限獨立,相互制約
非常務實的看到某些大型企業(yè)的,部門斗爭。從系統(tǒng)層面開始設計制約(這個應該非常符合老板心意)。這個對很多小型企業(yè)在成才過程中是非常有幫助的。
設計流程 減少犯錯
在電商行業(yè)非常清楚客服和倉庫的員工流動性,以及普遍受教育程度偏低,通過流程設計,而不是提高對用人的要求。這也是非常務實的方法。回顧之前在系統(tǒng)層面獨自設計支持中央預訂系統(tǒng),設計出來的自動傳真(當時網絡不如現(xiàn)在易得)及新訂單提醒(感謝施總的支持,增加音響進行聲音)等等,簡直覺得找到了知音。
多了解一些財務知識。
談到的兩點是數(shù)據(jù)之間需要有勾稽關系和不能修改歷史數(shù)據(jù),很驕傲我對財務的理解還是不錯,從未犯過這種不靠譜的錯誤。
跨平臺大型在線客服系統(tǒng)的技術構架
嘉賓談了的是一套客服系統(tǒng),比較多的關鍵字是客服妹子,可以看出IT從業(yè)者苦中作樂的精神。給我的體會是,客服系統(tǒng)都可以做成這樣。從一個項目到一個產品,在云計算的世界,可以好一個客服的組件,也是有很大的價值。和我的理想事業(yè)很接近,可以花上一生中最精華的時間,做好一個有價值的小眾專業(yè)的行業(yè)。
阿里分布式數(shù)據(jù)庫服務實踐
阿里的人就是高調,上場就調戲京東雙11前系統(tǒng)崩潰。我也經歷過很多系統(tǒng)崩潰,簡直是開發(fā)人員的噩夢,也是IT人員信用受損的嚴重事件(因此我一直比較注意防止崩潰及崩潰后的快速恢復)。回到分布式數(shù)據(jù)庫,這個是收獲最大的一個演講。雖然這個演講看上去是再給阿里云的DRDS做宣傳,但是嘉賓演講的很進行,深入淺出地介紹了分布式數(shù)據(jù)庫和單機數(shù)據(jù)庫的區(qū)別。對分布式事務的重新認識是一個很大的收獲,以前一直把教程中的數(shù)據(jù)庫原理中的事務定義,作為分布式事務需要解決的問題,其實不是。需要更加務實,在淘寶阿里這類訂單處理系統(tǒng)中,有一類對分布式事務的模式(異步消息機制);在其他領域會有其他模式分布式的事務模型,這些分布式模型肯定都不滿足單機的事務模型,但是可以滿足和解決相應領域的問題。
平臺架構的服務器監(jiān)控
一個APP的監(jiān)控模型,猜測項目立項的原因,有兩個。一個是和競爭對手的數(shù)據(jù)比較(UPYUN的對手主要是七牛),一個其實可以真正從用戶的角度看,用戶的體檢速度如何,以及影響用戶體驗速度的真實原因。目前一般行業(yè)還不會做的這么細,因為UPYUN是技術支持公司,因此一定需要用這些數(shù)據(jù)去說服和支持用戶。我們現(xiàn)在做的比較多的服務器的可用性、性能和應用的可用性、性能監(jiān)控。前端時間剛好再比較,發(fā)現(xiàn)互聯(lián)網上有不少好的監(jiān)控平臺,一般的創(chuàng)業(yè)公司,可以無需自己搭建監(jiān)控平臺,接入到相應的監(jiān)控平臺即可。下次再開文進行討論。
作者簡介:qiyadeng(www.qiyadeng.com)對互聯(lián)網技術、運營及市場領域有濃厚的興趣,喜愛思考、閱讀、討論;擅長Java開發(fā)及分布式技術。現(xiàn)專注于互聯(lián)網的創(chuàng)新產品--老來寶(http://www.laolaibao.com),立志于幫助廣大鳳凰(diao)男(si)提供補充養(yǎng)老金管理平臺。
摘要: guava是Java的一個擴展類庫,在google的許多項目中使用過了,現(xiàn)在最為一個 開源的Java類庫廣泛使用(http://code.google.com/p/guava-libraries/)。
guava類庫擴展的主要是這些相關類:collections(集合類),concurrency(并發(fā)),primitives,reflection(反射),comparison,I/O,hashi... 閱讀全文
簡單介紹一下8個Java牛人,他們?yōu)镴ava社區(qū),創(chuàng)建了框架(framework),產品或者是寫書,影響甚至改變了Java開發(fā)的方法(根據(jù)個人喜好排序)。 8.Tomcat創(chuàng)始人
James Duncan Davidson,是當時Sun公司的軟件工程師(1997-2001),創(chuàng)建了Java的Web服務器Tomcat,Tomcat廣泛應用于Java Web開發(fā)的各個領域。 7.測試驅動開發(fā)JUnit創(chuàng)始人
Kent Beck,極限編程和測試驅動開發(fā)方法的締造者。此外,他還創(chuàng)造了JUnit,JUnit目前一次成為Java開發(fā)測試的事實標準。基于測試驅動的開發(fā)方法和JUnit給Java開發(fā)的方法帶了巨大的變化。 6.Java Collections框架設計者
Joshua Bloch,領導設計了Java平臺的許多功能,包括Java 5.0 版本中飽受贊譽的Java Collections框架。2004年他離開Sun公司,成為Google的首席Java架構師,此外他的著作“Effective Java”基本上是學習Java的必讀之書。 5.JBoss創(chuàng)始人
Marc Fleury,在2001年創(chuàng)造了JBoss,JBoss是一個Java開源的應用服務器,也已經成為Java Web應用部署中的事實標準。后來他把JBoss買給了RedHat,之后繼續(xù)從事JBoss的開發(fā)工作。不過2007年他離開了RedHat去追求他的個人愛好。 4.Struts創(chuàng)始人
Craig Mcclanahan,創(chuàng)建了Struts,一個流行的基于Java的MVC開源框架,基本上很多Java開發(fā)者都知道如何開發(fā)Struts的應用程序。 3.Spring創(chuàng)始人
Rod Johnson,Spring框架的創(chuàng)始人,Spring Source的CEO。Spring是一個非常流行的Java應用程序開發(fā)的開源框架。此外,他的著作Expert One-to-One J2EE Design and Development,是J2EE最有影響力的一本書。 2.Hibernate創(chuàng)始人
Gavin King,Hibernate的創(chuàng)始人,一個流行的Java ORM解決方案;同時他也是Seam的創(chuàng)始人,此外他為EJB3.0和JPA也做出了突出的貢獻。 1.Java之父
James Gosling,1994年發(fā)明了Java語言,他創(chuàng)建了Java編譯器和虛擬機。在2010年,當Oracle收購Sun公司時,他離開了Sun公司。 原創(chuàng)文章,作者:qiyadeng,轉載請注明: 轉載自http://www.qiyadeng.com/ 本文鏈接地址: 你應該知道的8個Java牛人
1.申請開發(fā)者帳號 首先注冊百度的帳號,然后申請成為百度開發(fā)者(需要通過手機進行身份證驗證)。   2.新建應用 點擊菜單中的創(chuàng)建應用,我們目前選擇的是Web應用。   應用創(chuàng)建之后,選擇左邊菜單的云環(huán)境,環(huán)境類型需要選擇JAVA。  并新創(chuàng)建一個版本,輸入1作為版本號  3.在百度集成開發(fā)環(huán)境中開始開發(fā) 百度提供了基于Eclipse的插件,由于該插件不能支持最新的Eclipse版本。建議下載百度的一鍵安裝版本。百度文檔中介紹了如何使用開發(fā)環(huán)境,詳細請看集成開發(fā)環(huán)境使用。 打開百度集成開發(fā)環(huán)境,在Eclipse左下角點擊Login to Baidu,使用你的賬號登陸。然后點擊工具欄中百度Logo,選擇Import BAE Project,填入application和version  之后選擇Java作為Project Language。 4.解決項目錯誤 剛導入的BAE project,在Eclipse中會報錯。通過problems view可以看到是因為JRE環(huán)境配置不正確和Web運行環(huán)境設置不正確。 A.右鍵項目屬性--選擇JavaBuildPath,在Libraries中選擇Add Library,之后再選擇JRE System Library。  B.接下來把Java project轉換為Java Web Project(Eclipse中Java Project轉換為Java web Project),注意如果你的tomcat是6版本的話,請注意選擇Dynamic web Module的版本不超過2.5。 設置Web應用的運行環(huán)境,在servers view中新建一個tomcat服務器。  C.和A類似,在Java Build Path中加入 Server Runtime,選擇Tomcat。 D.修改hello.jsp,在hello.jsp中加入如下代碼 <% String path = request.getContextPath(); String basePath = request.getScheme()+"://"+request.getServerName()+":"+request.getServerPort()+path+"/"; %>
E.把項目部署到tomcat中。
至此項目錯誤全部解決,應該可以看到運行結果。

5.新建Servert測試
新建一個Servlet,HomeServlet,Eclipse會自動在web.xml中加入配置信息,HomeServet.java和web.xml的部分代碼如下:
protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException { doPost(request, response); }
/** * @see HttpServlet#doPost(HttpServletRequest request, HttpServletResponse response) */ protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException { PrintWriter out = response.getWriter(); out.println("<h1>BAE Servlet Test.</h1>"); }
web.xml中部分代碼
<servlet> <description></description> <display-name>HomeServlet</display-name> <servlet-name>HomeServlet</servlet-name> <servlet-class>com.qiyadeng.HomeServlet</servlet-class> </servlet> <servlet-mapping> <servlet-name>HomeServlet</servlet-name> <url-pattern>/HomeServlet</url-pattern> </servlet-mapping> 運行tomcat,可以看到如下運行成功,這樣你就可以像一般的Java Web Project一樣進行開發(fā)。

6.最后
BAE中Java環(huán)境中百度使用的Jetty,而不是tomcat,Jetty的好處是不需要頻繁的重啟,修改的代碼即時就可看到運行結果。
通過SVN提交代碼到BAE,如果有需要做小的修改,可以通過百度的在線編輯工具直接修改。

原創(chuàng)文章,轉載請注明: 轉載自http://www.qiyadeng.com/
本文鏈接地址: 百度開發(fā)者中心BAE新建Java應用
1.申請開發(fā)者帳號 首先注冊百度的帳號,然后申請成為百度開發(fā)者(需要通過手機進行身份證驗證)。
2.新建應用 點擊菜單中的創(chuàng)建應用,我們目前選擇的是Web應用。
應用創(chuàng)建之后,選擇左邊菜單的云環(huán)境,環(huán)境類型需要選擇JAVA。
并新創(chuàng)建一個版本,輸入1作為版本號
3.在百度集成開發(fā)環(huán)境中開始開發(fā) 百度提供了基于Eclipse的插件,由于該插件不能支持最新的Eclipse版本。建議下載百度的一鍵安裝版本。百度文檔中介紹了如何使用開發(fā)環(huán)境,詳細請看集成開發(fā)環(huán)境使用。 打開百度集成開發(fā)環(huán)境,在Eclipse左下角點擊Login to Baidu,使用你的賬號登陸。然后點擊工具欄中百度Logo,選擇Import BAE Project,填入application和version
之后選擇Java作為Project Language。 4.解決項目錯誤 剛導入的BAE project,在Eclipse中會報錯。通過problems view可以看到是因為JRE環(huán)境配置不正確和Web運行環(huán)境設置不正確。 A.右鍵項目屬性--選擇JavaBuildPath,在Libraries中選擇Add Library,之后再選擇JRE System Library。
B.接下來把Java project轉換為Java Web Project(Eclipse中Java Project轉換為Java web Project),注意如果你的tomcat是6版本的話,請注意選擇Dynamic web Module的版本不超過2.5。 設置Web應用的運行環(huán)境,在servers view中新建一個tomcat服務器。
C.和A類似,在Java Build Path中加入 Server Runtime,選擇Tomcat。 D.修改hello.jsp,在hello.jsp中加入如下代碼 <% String path = request.getContextPath(); String basePath = request.getScheme()+"://"+request.getServerName()+":"+request.getServerPort()+path+"/"; %>
E.把項目部署到tomcat中。
至此項目錯誤全部解決,應該可以看到運行結果。
5.新建Servert測試
新建一個Servlet,HomeServlet,Eclipse會自動在web.xml中加入配置信息,HomeServet.java和web.xml的部分代碼如下:
protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException { doPost(request, response); }
/** * @see HttpServlet#doPost(HttpServletRequest request, HttpServletResponse response) */ protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException { PrintWriter out = response.getWriter(); out.println("<h1>BAE Servlet Test.</h1>"); }
web.xml中部分代碼
<servlet> <description></description> <display-name>HomeServlet</display-name> <servlet-name>HomeServlet</servlet-name> <servlet-class>com.qiyadeng.HomeServlet</servlet-class> </servlet> <servlet-mapping> <servlet-name>HomeServlet</servlet-name> <url-pattern>/HomeServlet</url-pattern> </servlet-mapping> 運行tomcat,可以看到如下運行成功,這樣你就可以像一般的Java Web Project一樣進行開發(fā)。
6.最后
BAE中Java環(huán)境中百度使用的Jetty,而不是tomcat,Jetty的好處是不需要頻繁的重啟,修改的代碼即時就可看到運行結果。
通過SVN提交代碼到BAE,如果有需要做小的修改,可以通過百度的在線編輯工具直接修改。

空指針異常(Null Pointer Exception)是我們平時最容易碰到的,也是最令人討厭的異常。本文介紹如何避免出現(xiàn)空指針異常。 首先我們看如下的示例 private Boolean isFinished(String status) { if (status.equalsIgnoreCase("Finish")) { return Boolean.TRUE; } else { return Boolean.FALSE; } } 如果status的值為空的話,那么將會出現(xiàn)空指針異常(本例第2行)。所以我們應該使用如下的方法
private Boolean isFinished(String status) { if ("Finish".equalsIgnoreCase(status)) { return Boolean.TRUE; } else { return Boolean.FALSE; } } 這樣的話,如果status為空,也不會出現(xiàn)空指針異常。相信我們大多數(shù)朋友已經知道這樣的方法了,如果一個對象可能為null,那么不需要直接調用它的方法。
接下來我將接著提供幾種避免空指針的建議。
1.判斷Collection是否為空。
2.使用一些判斷方法。
3.assert關鍵字。
4.Assert類。
5.異常處理。
6.太多的點.操作語法。
7.使用StringUtils類
1.判斷Collection是否為空
Collection 為空是指Collection中沒有元素。一些開發(fā)者如果碰到Collection中沒有元素的時候,經常return null,更好的做法是,你應該return Collections.EMPTY_LIST,Collections.EMPTY_SET或者是Collections.EMPTY_MAP.
錯誤的代碼
public static List getEmployees() { List list = null; return list; }
正確的代碼
public static List getEmployees() { List list = Collections.EMPTY_LIST; return list; }
2.使用一些判斷方法
使用一些方法如contains(),indexOf(),isEmpty(),containsKey(),ContainsValue和hasNext()等來判斷,確保不存在空值。
示例:
String myName = "qiyadeng"; List list = Collections.EMPTY_LIST; boolean exist = list.contains(myName); int index = list.indexOf(myName); boolean isEmpty =list.isEmpty(); Map map =Collections.EMPTY_MAP; exist=map.containsKey(myName); exist=map.containsValue(myName); isEmpty=map.isEmpty(); Set set=Collections.EMPTY_SET; exist=set.contains(myName); isEmpty=set.isEmpty(); Iterator iterator; exist = iterator.hasNext();
3.assert關鍵字
在Java1.4版本之后,提供了斷言assert來確定你的代碼中的假設。使用的語法如下:
expression1是一個boolean表達式,如果expression1返回的false,系統(tǒng)將會拋出AssertError(沒有詳細信息)。
另外一種使用方法
assert expression1:expression2 如果expression1返回false,那么系統(tǒng)將會拋出AssertError,并且詳細信息為expression2。
示例:
public static String getManager(String employeeId) { assert (employeeId != null) : "employeeId must be not null"; return "qiyadeng"; } 我使用getManager(null)來調用getManger方法,最后運行的結果是"java.lang.AssertionError:employeedId must be not null"
注意記得使用java選項中加入-enableassertion開啟assertion功能。
4.Assert類
Assert類在com.bea.core.repackaged.springframework.util包中,有許多方法可以用于斷言。
public static String getManager(String employeeId) { Assert.notNull(employeeId, "employeeId must be not null"); Assert.hasLength(employeeId, "employeeId must has length greater than 0"); return "qiyadeng"; } 當我同樣使用getManager(null)來調用getManager方法,將獲得信息"java.lang.IllegalArgumentException: employeeId must be not null"。
5.異常處理
使用try catch處理異常或是檢查變量是否為空。
public static String getManager(String employeeId) { return null; } 如上代碼,我使用下面方法調用
String managerId = getManager("A015"); System.out.println(managerId.toString()); 將會發(fā)生"java.lang.NullPointerException",為了處理這個異常,我們應該使用try catch來處理異常或者是檢查變量是否為null。
try-catch方法
String managerId = getManager("A015"); try { System.out.println(managerId.toString()); } catch (NullPointerException npe) { //write your code here } 或者是對變量進行檢查
String managerId = getManager("A015"); if (managerId != null) { System.out.println(managerId.toString()); } else { //write your code here }
6.不要太多的點.操作語法
一些開發(fā)者使用太多的這樣的方法來減少代碼,但是這個對后面的維護和異常處理都是不太好的。
錯誤的寫法
String attrValue = (String)findViewObject("VO_NAME").getCurrentRow().getAttribute("Attribute_NAME"); 正確的寫法
ViewObject vo = findViewObject("VO_NAME"); Row row = vo.getCurrentRow(); String attrValue = (String)row.getAttribute("Attribute_NAME");
7.使用StringUtils類
StringUtil是org.apache.commns.lang包中的類,我們可以使用該類來避免空指針異常。
例如 StringUtils.isEmpty(),StringUtils.isBlank,StringUtils.equals()等等,更多的你可以參考文檔。
為了不出現(xiàn)空指針異常,在寫代碼的過程中需要時刻檢查你的代碼是否會拋出NullPointerException,如果你沒有時間及時調整的話,使用//TODO標記,便于你后面解決問題。
現(xiàn)在經常需要根據(jù)用戶提供的位置,提供一些和位置相關的信息。有時可以直接確定用戶的經度和緯度,有時不一定可以確定用戶的經度和緯度信息,用戶是 通過輸入一些路名、標志性建筑或是商場名等位置,但是我們的數(shù)據(jù)庫可能并沒有存法用戶可能輸入的這些位置信息的經度緯度,這時候可以使用一些地圖提供的 API來確定,用戶所輸入的位置信息的經度和緯度。 我們使用百度地圖提供的GeoCoding API實現(xiàn)從位置信息到經度緯度的轉換,詳細的使用說明可以參考 GeoCoding API。我們這里做一個簡單的演示 public String getGeoCode(String query) throws ClientProtocolException, IOException{ HttpClient httpClient = new DefaultHttpClient(); String url = geoCodeRequestUrl(query); logger.log(Level.INFO, url); HttpGet httpget = new HttpGet(url); ResponseHandler<String> responseHandler = new BasicResponseHandler(); String responseBody = httpClient.execute(httpget, responseHandler);//百度返回的經度緯度信息xml logger.log(Level.INFO,"baidu response:"+responseBody); return responseBody; } public String geoCodeRequestUrl(String query) throws UnsupportedEncodingException{ String url = WeChatConstant.BASEURL + "geocoder?address=" + URLEncoder.encode(query,"UTF-8") + "&key=" + WeChatConstant.MAPKEY + "&output=" + WeChatConstant.OUTPUTFORMAT; return url; } 使用JUnit進行測試 @Test public void testGeoCode() throws Exception { BaiduMapService bms = new BaiduMapService(); String response = bms.getGeoCode("上地十街十號"); BaiduGeoCodeResponse res = BaiduGeoCodeResponse.getBaiduGeoCode(response);//解析xml System.out.println(res.toString()); } 輸出的結果 <GeocoderSearchResponse> <status>OK</status> <result> <location> <lat>40.057098</lat> <lng>116.307175</lng> </location> <precise>1</precise> <confidence>80</confidence> <level>道路</level> </result> </GeocoderSearchResponse> BaiduGeoCodeResponse [lat=40.057098, lng=116.307175]
到了一個較陌生的環(huán)境,經常會在周邊找一些基礎設施,比如銀行,商場,餐廳等(還有一種更急切的是找?guī)Mㄟ^百度提供的地圖API,可以在你的應用中簡單做到,詳情可閱讀 Place API。我們以查找周邊銀行作為示例,需確定的參數(shù)至少有三個,要查找的位置的經度和緯度,需要查找的內容的類型或是關鍵字。 public String getPalace(String query,String lat,String lng) throws ClientProtocolException, IOException{ HttpClient httpClient = new DefaultHttpClient(); String url = palceRequestUrl(query,lat,lng); logger.log(Level.INFO, url); HttpGet httpget = new HttpGet(url); ResponseHandler<String> responseHandler = new BasicResponseHandler(); String responseBody = httpClient.execute(httpget, responseHandler);//位置xml logger.log(Level.INFO,"baidu response:"+responseBody); return responseBody; } public String palceRequestUrl(String query,String lat,String lng) throws UnsupportedEncodingException { String url = WeChatConstant.BASEURL + "place/search?query=" + URLEncoder.encode(query,"UTF-8") + "&key=" + WeChatConstant.MAPKEY +"&location="+lat+","+lng +"&radius=2000"+"&output=" + WeChatConstant.OUTPUTFORMAT; return url; } Junit測試 @Test public void testGetBaiduPlace() throws Exception{ BaiduMapService bms = new BaiduMapService(); String response = bms.getPalace("銀行", "39.915", "116.404"); List<BaiduPlaceResponse> list = BaiduPlaceResponse.getBaiduPlace(response); for(BaiduPlaceResponse res:list){ System.out.println(res.toString()); } } 輸出內容(省略部分內容) <?xml version="1.0" encoding="utf-8" ?> <PlaceSearchResponse> <status>OK</status> <results> <result> <name>中國工商銀行東長安街支行</name> <location> <lat>39.915891</lat> <lng>116.41867</lng> </location> <address>東城區(qū)東長安街1號東方廣場西三辦公樓1樓</address> <uid>a025683c73033c35a21de987</uid> <detail_url>http://api.map.baidu.com/place/detail?uid=a025683c73033c35a21de987&amp;output=html&amp;source=placeapi</detail_url> <tag>銀行,王府井/東單</tag> </result> </results> </PlaceSearchResponse> BaiduPlaceResponse [name=中國工商銀行東長安街支行, telephone=null, address=東城區(qū)東長安街1號東方廣場西三辦公樓1樓, lat=39.915891, lng=116.41867, tag=null, detailUrl=http://api.map.baidu.com/place/detail?uid=a025683c73033c35a21de987&output=html&source=placeapi]
位置識別這是實際應用經常應用的消息,特別是很多商家,通過了解用戶位置,給用戶提供特別的產品或是商場的推薦。其中用戶可能發(fā)送兩種類型的消息: 1.微信地理位置信息 2.路名、標志性建筑或是商場名稱 1.微信地理位置消息認識一下,微信地理位置消息,包含一些什么信息 <xml> <ToUserName><![CDATA[toUser]]></ToUserName> <FromUserName><![CDATA[fromUser]]></FromUserName> <CreateTime>1351776360</CreateTime> <MsgType><![CDATA[location]]></MsgType> <Location_X>23.134521</Location_X> <Location_Y>113.358803</Location_Y> <Scale>20</Scale> <Label><![CDATA[位置信息]]></Label> <MsgId>1234567890123456</MsgId> </xml>
包含的主要信息有經度緯度和Label的位置。可以根據(jù)label中描述的位置信息,提供給用戶對應的服務。也可根據(jù)用戶的經度緯度信息,提供你最近的產品或是有地域性的產品。
首先根據(jù)微信的地理位置信息,定義WeChatLocationMessage類,并能把Xml轉換為WeChatLocationMessage對象 public class WeChatLocationMessage { private String toUserName; private String fromUserName; private String createTime; private String msgType; private String locationx; private String localtiony; private String scale; private String label; private String msgId; public static WeChatLocationMessage getWeChatLocationMessage(String xml){ XStream xstream = new XStream(new DomDriver()); WeChatLocationMessage message = null; xstream.alias("xml", WeChatLocationMessage.class); xstream.aliasField("ToUserName", WeChatLocationMessage.class, "toUserName"); xstream.aliasField("FromUserName", WeChatLocationMessage.class, "fromUserName"); xstream.aliasField("CreateTime", WeChatLocationMessage.class, "createTime"); xstream.aliasField("MsgType", WeChatLocationMessage.class, "msgType"); xstream.aliasField("Location_X", WeChatLocationMessage.class, "locationx"); xstream.aliasField("Location_Y", WeChatLocationMessage.class, "localtiony"); xstream.aliasField("Scale", WeChatLocationMessage.class, "scale"); xstream.aliasField("Label", WeChatLocationMessage.class, "label"); xstream.aliasField("MsgId", WeChatLocationMessage.class, "msgId"); message = (WeChatLocationMessage)xstream.fromXML(xml); return message; } //getter and setter } 本文利用百度的地圖API,查找最近的銀行做為示例。 public String getPalace(String query,String lat,String lng) throws ClientProtocolException, IOException{ HttpClient httpClient = new DefaultHttpClient(); String url = palceRequestUrl(query,lat,lng); logger.log(Level.INFO, url); HttpGet httpget = new HttpGet(url); ResponseHandler<String> responseHandler = new BasicResponseHandler(); String responseBody = httpClient.execute(httpget, responseHandler); logger.log(Level.INFO,"baidu response:"+responseBody); return responseBody; } public String palceRequestUrl(String query,String lat,String lng) throws UnsupportedEncodingException { String url = WeChatConstant.BASEURL + "place/search?query=" + URLEncoder.encode(query,"UTF-8") + "&key=" + WeChatConstant.MAPKEY +"&location="+lat+","+lng +"&radius=2000"+"&output=" + WeChatConstant.OUTPUTFORMAT; return url; } 輸出的結果 <PlaceSearchResponse> <status>OK</status> <results> <result> <name>中國工商銀行東長安街支行</name> <location> <lat>39.915891</lat> <lng>116.41867</lng> </location> <address>東城區(qū)東長安街1號東方廣場西三辦公樓1樓</address> <uid>a025683c73033c35a21de987</uid> <detail_url>http://api.map.baidu.com/place/detail?uid=a025683c73033c35a21de987&amp;output=html&amp;source=placeapi </detail_url> <tag>銀行,王府井/東單</tag>
</result> </results> </PlaceSearchResponse> 接下來,把百度地圖反映出來的最近位置信息,以圖文消息的格式展示給微信用戶 public static String getWeChatReplyNewsMessageByBaiduPlace(List<BaiduPlaceResponse> placeList, double lat, double lng,String userName, int size){ WeChatReplyNewsMessage newsMessage = new WeChatReplyNewsMessage(); List<Item> items = new ArrayList<Item>(); StringBuffer strBuf = new StringBuffer(); logger.log(Level.INFO,"placeList count="+placeList.size()); newsMessage.setItems(items); if(placeList.size()>size){ newsMessage.setArticleCount(size); } else{ newsMessage.setArticleCount(placeList.size()); } logger.log(Level.INFO,"article count="+newsMessage.getArticleCount()); newsMessage.setCreateTime(new Date().getTime()+""); newsMessage.setMsgType("news"); newsMessage.setFuncFlag("0"); newsMessage.setToUserName(userName); newsMessage.setFromUserName(WeChatConstant.FROMUSERNAME); for(int i = 0;i <newsMessage.getArticleCount();i++){ BaiduPlaceResponse place = placeList.get(i); Double distance = GeoUtil.DistanceOfTwoPoints(Double.valueOf(place.getLng()), Double.valueOf(place.getLat()), lng, lat, GaussSphere.Beijing54); Item item = new Item(); item.setTitle(place.getName()+"["+distance+"米]"+"\n"+place.getAddress()+"\n"+place.getTelephone()); item.setPicUrl(""); item.setUrl(place.getDetailUrl()); item.setDescription(""); items.add(item); } logger.log(Level.INFO,"newMessage="+newsMessage.toString()); strBuf = strBuf.append(getWeChatNewsMessage(newsMessage)); return strBuf.toString(); } public static String getWeChatNewsMessage(WeChatReplyNewsMessage newsMessage){ XStream xstream = new XStream(new DomDriver()); xstream.alias("xml", WeChatReplyNewsMessage.class); xstream.aliasField("ToUserName", WeChatReplyNewsMessage.class, "toUserName"); xstream.aliasField("FromUserName", WeChatReplyNewsMessage.class, "fromUserName"); xstream.aliasField("CreateTime", WeChatReplyNewsMessage.class, "createTime"); xstream.aliasField("MsgType", WeChatReplyNewsMessage.class, "msgType"); xstream.aliasField("ArticleCount", WeChatReplyNewsMessage.class, "articleCount"); xstream.aliasField("Content", WeChatReplyNewsMessage.class, "content"); xstream.aliasField("FuncFlag", WeChatReplyNewsMessage.class, "funcFlag"); xstream.aliasField("Articles", WeChatReplyNewsMessage.class, "items"); xstream.alias("item", Item.class); xstream.aliasField("Title", Item.class, "title"); xstream.aliasField("Description", Item.class, "description"); xstream.aliasField("PicUrl", Item.class, "picUrl"); xstream.aliasField("Url", Item.class, "url"); return xstream.toXML(newsMessage); } 2.路名、標志性建筑或是商場名稱對路名、標志性建筑等信息,方法還是通過第三方地圖信息,確定輸入的位置信息的經度緯度。 本文使用百度地圖API,確定所查找的位置的經度和緯度。 public String getGeoCode(String query) throws ClientProtocolException, IOException{ HttpClient httpClient = new DefaultHttpClient(); String url = geoCodeRequestUrl(query); logger.log(Level.INFO, url); HttpGet httpget = new HttpGet(url); ResponseHandler<String> responseHandler = new BasicResponseHandler(); String responseBody = httpClient.execute(httpget, responseHandler); logger.log(Level.INFO,"baidu response:"+responseBody); return responseBody; } public String geoCodeRequestUrl(String query) throws UnsupportedEncodingException{ String url = WeChatConstant.BASEURL + "geocoder?address=" + URLEncoder.encode(query,"UTF-8") + "&key=" + WeChatConstant.MAPKEY + "&output=" + WeChatConstant.OUTPUTFORMAT; return url; } 確定了經度和緯度,問題就變成和第1種消息類型一致了,根據(jù)經度緯度去做相應處理。
3.源代碼本文的代碼較長,提供源代碼下載。 WeChatDemo下載
本文介紹,如果把Java Project轉換為Java Web Project,應該在多數(shù)的Eclipse的版本都類似。 1.Java Project一個Java Projec,在Eclipse中顯示的是一個“J”的藍色文件夾。
2.Project Facets右鍵項目屬性Properties,右側選擇菜單Project Facets,點擊converted to faceted form...
勾選dynamic web module
選擇下面的further configuration available
項目中的Web目錄和設置保持一致。
3.Java Web Project這樣你就轉換到了Java Web Project。 
1.新建Project 新建Java Project,并把mongo-java-driver驅動加入到項目bulid path中,如果你使用的是maven增加依賴。 <dependency> <groupId>org.mongodb</groupId> <artifactId>mongo-java-driver</artifactId> <version>2.10.1</version> </dependency> 2.連接上MongoDB //>2.10版本 MongoClient mongo = new MongoClient( "localhost" , 27017 );
//老版本 Mongo mongo = new Mongo("localhost", 27017); 如果需要驗證,需要輸入用戶名和密碼 MongoClient mongoClient = new MongoClient(); DB db = mongoClient.getDB("database name"); boolean auth = db.authenticate("username", "password".toCharArray()); 3.MongoDB數(shù)據(jù)庫 得到MongoDB中的數(shù)據(jù)庫,如果數(shù)據(jù)庫名不存在,MongoDB會自動創(chuàng)建 DB db = mongo.getDB("database name"); 顯示所有的數(shù)據(jù)庫 List<String> dbs = mongo.getDatabaseNames(); for(String db : dbs){ System.out.println(db); } 4.MongoDB Collection(MongoDB表) 得到數(shù)據(jù)庫中的表 DB db = mongo.getDB("testdb"); DBCollection table = db.getCollection("user"); 顯示數(shù)據(jù)庫中的所有表 DB db = mongo.getDB("testdb"); Set<String> tables = db.getCollectionNames(); for(String coll : tables){ System.out.println(coll); } 5.插入、查找、更新、刪除操作 插入數(shù)據(jù),向Collection(表)中插入一個Document DBCollection table = db.getCollection("user"); BasicDBObject document = new BasicDBObject(); document.put("name", "qiyadeng"); document.put("age", 30); document.put("createdDate", new Date()); table.insert(document); 更新Document中的name="qiyadeng.com" DBCollection table = db.getCollection("user");
BasicDBObject query = new BasicDBObject(); query.put("name", "qiyadeng");
BasicDBObject newDocument = new BasicDBObject(); newDocument.put("name", "qiyadeng.com");
BasicDBObject updateObj = new BasicDBObject(); updateObj.put("$set", newDocument); table.update(query, updateObj); 從Collection中查找name="qiyadeng.com"的Document DBCollection table = db.getCollection("user"); BasicDBObject searchQuery = new BasicDBObject(); searchQuery.put("name", "qiyadeng.com"); DBCursor cursor = table.find(searchQuery); while (cursor.hasNext()) { System.out.println(cursor.next()); } 刪除name="qiyadeng"的Document DBCollection table = db.getCollection("user"); BasicDBObject searchQuery = new BasicDBObject(); searchQuery.put("name", "qiyadeng.com"); table.remove(searchQuery);
6.完整的例子 package com.qiyadeng.mongodb;
import java.util.Date;
import com.mongodb.BasicDBObject; import com.mongodb.DB; import com.mongodb.DBCollection; import com.mongodb.DBCursor; import com.mongodb.MongoClient;
public class MongoDBSample {
public static void main(String[] args) throws Exception{ /**** Connect to MongoDB ****/ //2.10.0后,使用MongoClient MongoClient mongo = new MongoClient("localhost", 27017); /**** Get database ****/ // if database doesn't exists, MongoDB will create it for you DB db = mongo.getDB("testdb"); /**** Get collection / table from 'testdb' ****/ // if collection doesn't exists, MongoDB will create it for you DBCollection table = db.getCollection("user"); /**** Insert ****/ // create a document to store key and value BasicDBObject document = new BasicDBObject(); document.put("name", "qiyadeng"); document.put("age", 30); document.put("createdDate", new Date()); table.insert(document); /**** Find and display ****/ BasicDBObject searchQuery = new BasicDBObject(); searchQuery.put("name", "qiyadeng"); DBCursor cursor = table.find(searchQuery); while (cursor.hasNext()) { System.out.println(cursor.next()); } /**** Update ****/ // search document where name="qiyadeng" and update it with new values BasicDBObject query = new BasicDBObject(); query.put("name", "qiyadeng"); BasicDBObject newDocument = new BasicDBObject(); newDocument.put("name", "qiyadeng.com"); BasicDBObject updateObj = new BasicDBObject(); updateObj.put("$set", newDocument); table.update(query, updateObj); /**** Find and display ****/ BasicDBObject searchQuery2 = new BasicDBObject().append("name", "qiyadeng.com"); DBCursor cursor2 = table.find(searchQuery2); while (cursor2.hasNext()) { System.out.println(cursor2.next()); } } }
輸出 { "_id" : { "$oid" : "51444c88874c79654063356b"} , "name" : "qiyadeng" , "age" : 30 , "createdDate" : { "$date" : "2013-03-16T10:42:16.555Z"}} { "_id" : { "$oid" : "51444c88874c79654063356b"} , "age" : 30 , "createdDate" : { "$date" : "2013-03-16T10:42:16.555Z"} , "name" : "qiyadeng.com"}
使用mongo驗證創(chuàng)建的數(shù)據(jù)庫testdb,collection user是否存在。
本文介紹如何安裝在windows 7中安裝MongoDB。 注:MongoDB并不像Windows上安裝其他軟件,只需要下載Zip包并解壓,然后配置數(shù)據(jù)存放目錄并啟動即可。 1.下載MongoDB從MongoDB官方網站,根據(jù)你的平臺選擇對應的windows的壓縮包并解壓,本文解壓到D:\mongodb\。
注:如果需要在命令行中快速使用MongoDB bin目錄下的命令,可以將D:\mongoDB\bin加入到Window環(huán)境變量。 2.配置數(shù)據(jù)文件在D:\mongodb\創(chuàng)建mongo.config文件,如下(并在d:\mongodb目錄下新建data,log文件夾) ##數(shù)據(jù)存儲的位置 dbpath=D:\mongodb\data ##所有的輸出位置 logpath=D:\mongodb\log\mongo.log ##日志讀寫操作 diaglog=3 3.運行MongoDB Server在命令控制行,切換到d:\mongodb\bin目錄下,使用命令mongod.exe --config d:\mongdb\mongo.config啟動MongoDb Server。 D:\mongodb\bin>mongod.exe --config d:\mongodb\mongo.config all output going to: D:\mongodb\log\mongo.log 4.連接MongoDB新開啟一個命令行控制窗口,使用mongo.exe連接MongoDB Server. 5.設置MongoDB為Windows服務在命令行控制窗口,加入--install選項可以把MongoDB安裝為Windows服務。 D:\mongodb\bin>mongod.exe --config d:\mongodb\mongo.config 啟動MongoDB的命令為:net start MongoDB 停車MongODB的命令為:net stop MongoDB 刪除MongoDB的命令為:mongod --remove
|