
2010年8月22日
Array排序
protected function applicationCompleteHandler(event:FlexEvent):void
{
var array:Array = [];
array.push(new Vga("a",10));
array.push(new Vga("c",2));
array.push(new Vga("f",1.3));
array.push(new Vga("d",1.1));
array.push(new Vga("e",16));
array.push(new Vga("b",0));
trace(array.toString());
//output: [a,10],[c,2],[f,1.3],[d,1.1],[e,16],[b,0]
var defaultSort:Array = array.sort();//默認排序
trace(defaultSort.toString());
//output: [a,10],[b,0],[c,2],[d,1.1],[e,16],[f,1.3]
var sortFunArray:Array = array.sort(sortFun);//使用自定義方法排序
trace(sortFunArray.toString());
//output: [b,0],[d,1.1],[f,1.3],[c,2],[a,10],[e,16]
}
/**自定義排序方法*/
public function sortFun(a:Vga,b:Vga):int{
if(a.price < b.price){
return -1; //a在前,b在后
}else if(a.price == b.price){
return 0; //ab位置不變
}else{
return 1; //b在前,a在后
}
}
/**排序VO對象*/
public class Vga
{
public var name:String;
public var price:Number;
public function Vga(name:String,price:Number)
{
this.name = name;
this.price = price;
}
public function toString():String{
return "["+this.name+","+this.price+"]";
}
}
ArrayCollection排序
<?xml version="1.0" encoding="utf-8"?>
<mx:Application xmlns:mx="http://www.adobe.com/2006/mxml" layout="absolute">
<mx:Script>
<![CDATA[
import mx.collections.SortField;
import mx.collections.Sort;
import mx.collections.ArrayCollection;
private var acSort:ArrayCollection=
new ArrayCollection([{id:0,userName:"zhangSan",age:21},
{id:2,userName:"liSi",age:24},
{id:1,userName:"wangWu",age:31}]);
private function sortAc():ArrayCollection{
var sort:Sort=new Sort();
//按照ID升序排序
sort.fields=[new SortField("id")];
//按照userName降序排序
sort.fields=[new SortField("userName",true,true)];
//先按ID升序,再按userName降序
sort.fields[new SortField("id"),new SortField("userName",true,true)];
acSort.sort=sort;
acSort.refresh();//更新
return acSort;
}
/*
其實看看API就一目了然
SortField () 構造函數
public function SortField(name:String = null,
caseInsensitive:Boolean = false,
descending:Boolean = false,
numeric:Object = null)
參數
name:String (default = null) — 此字段用來進行比較的屬性的名稱。如果該對象為簡單類型,則傳遞 null。
caseInsensitive:Boolean (default = false) — 在對字符串進行排序時,指示比較運算符是否忽略值的大小寫。
descending:Boolean (default = false) — 指示比較運算符是否按降序排列項目。
numeric:Object (default = null) — 指示比較運算符是否按編號而不按字母順序比較排序項目。
*/
]]>
</mx:Script>
</mx:Application>
posted @
2013-03-17 12:19 wkkyo 閱讀(4425) |
評論 (0) |
編輯 收藏
項目中需要用到openfire的文件傳輸,但是客戶端使用flex,官方提供的xiff包中并沒有封裝文件傳輸的功能,沒辦法,研究了幾天,在google和官方smock源碼的幫助下終于實現了xiff下的文件傳輸,在這里做個總結。
openfire服務器是基于xmpp協議的,XMPP支持兩種文件流傳輸協議,SOCKS5 Bytestreams和 In-Band Bytestreams,SOCKS5是直接發送二進制流,而IBB是將文件轉成base64碼進行然后用message的形式進行傳輸,我這里僅實現了SOCKS5的文件代理傳輸。
SOCKS5文件傳輸需要用到兩個協議,XEP-0065和XEP-0096
XEP-0096定義文件傳輸協議,提供了一個模塊化框架使能交換被傳輸文件的信息以及參數的協商,也就是在傳輸文件之前協商將要傳輸的文件信息。
XEP-0065定義SOCKS5流傳輸標準協議,提供用于在任意兩個XMPP用戶之間建立字節流并進行文件傳輸。
根據我的理解,文件傳輸的過程分為協商,建立socks5連接,二進制傳輸這三個階段
協商的過程最復雜,然后是建立連接,傳輸就比較簡單,下面一個一個來講
協商包括初始方、目標方、代理方,初始方就是發送文件方,目標方即文件接收方,代理方是socks5代理服務器,
協商過程就是三方互相發送xml來交換信息的過程,通俗點就是三個人溝通一下傳什么文件和怎么傳文件。
首先遵循XMP-0096協議,初始方給目標方發送包含文件信息的xml
<iq to="android@192.168.1.113/Spark 2.6.3" type="set" id="iq_13" from="iphone@192.168.1.113/xiff">
<si profile="http://jabber.org/protocol/si/profile/file-transfer" mime-type="text/plain" id="82B0C697-C1DE-93F9-103E-481C8E7A3BD8" xmlns="http://jabber.org/protocol/si">
<feature xmlns="http://jabber.org/protocol/feature-neg">
<x xmlns="jabber:x:data" type="form">
<field var="stream-method" type="list-single">
<option><value>http://jabber.org/protocol/bytestreams</value></option>
<option><value>http://jabber.org/protocol/ibb</value></option>
</field>
</x>
</feature>
<file xmlns="http://jabber.org/protocol/si/profile/file-transfer" name="img0545.png" size="152443"><desc>send</desc></file>
</si>
</iq>
目標方接收到信息后發送回執,表示同意接收文件
<iq id="iq_13" to="iphone@192.168.1.113/xiff" from="android@192.168.1.113/Spark 2.6.3" type="result">
<si xmlns="http://jabber.org/protocol/si">
<feature xmlns="http://jabber.org/protocol/feature-neg">
<x xmlns="jabber:x:data" type="submit">
<field var="stream-method">
<value>http://jabber.org/protocol/bytestreams</value>
<value>http://jabber.org/protocol/ibb</value>
</field>
</x>
</feature>
</si>
</iq>

這時進入XEP-0065協議階段
初始方給服務器發送信息,請求提供代理服務器
<iq id="iq_15" type="get"><query xmlns="http://jabber.org/protocol/disco#items" /></iq>

服務器回復信息,告知可用的代理
<iq type="result" id="iq_15" to="iphone@192.168.1.113/xiff">
<query xmlns="http://jabber.org/protocol/disco#items">
<item jid="proxy.192.168.1.113" name="Socks 5 Bytestreams Proxy"/>
<item jid="pubsub.192.168.1.113" name="Publish-Subscribe service"/>
<item jid="conference.192.168.1.113" name="公共房間"/>
<item jid="search.192.168.1.113" name="User Search"/>
</query>
</iq>

這里選擇name=“Socks 5 Bytestreams Proxy”的代理,初始方給這個代理發送信息獲取代理連接信息
<iq id="iq_17" to="proxy.192.168.1.113" type="get"><query xmlns="http://jabber.org/protocol/bytestreams" /></iq>
代理方回復信息,告知初始方代理的jid、IP、端口等信息
<iq type="result" id="iq_17" from="proxy.192.168.1.113" to="iphone@192.168.1.113/xiff">
<query xmlns="http://jabber.org/protocol/bytestreams">
<streamhost jid="proxy.192.168.1.113" host="192.168.1.113" port="7777"/>
</query>
</iq>

初始方收到代理信息后將代理的信息發送給目標方
<iq to="android@192.168.1.113/Spark 2.6.3" type="set" id="iq_19" from="iphone@192.168.1.113/xiff">
<query xmlns="http://jabber.org/protocol/bytestreams" mode="tcp" sid="82B0C697-C1DE-93F9-103E-481C8E7A3BD8">
<streamhost port="7777" host="192.168.1.113" jid="proxy.192.168.1.113" />
</query>
</iq>

然后就進入連接階段,也就是初始方和目標方分別和代理建立socks5連接的過程。(關于SOCKS5協議連接,我之后會補充)。
目標方收到代理信息后和代理建立socket連接(使用SOCKS5協議連接),連接成功后通知初始方使用的代理jid
<iq id="iq_19" to="iphone@192.168.1.113/xiff" type="result" from="android@192.168.1.113/Spark 2.6.3">
<query xmlns="http://jabber.org/protocol/bytestreams">
<streamhost-used jid="proxy.192.168.1.113"/>
</query>
</iq>

初始方開始與代理建立socket連接(也使用SOCKS5協議),連接成功后給代理發送請求,要求激活文件流
<iq to="proxy.192.168.1.113" type="set" id="iq_21" from="iphone@192.168.1.113/xiff">
<query xmlns="http://jabber.org/protocol/bytestreams" sid="82B0C697-C1DE-93F9-103E-481C8E7A3BD8">
<activate>android@192.168.1.113/Spark 2.6.3</activate>
</query>
</iq>

代理回復激活成功信息
<iq type="result" id="iq_21" from="proxy.192.168.1.113" to="iphone@192.168.1.113/xiff"/>

初始方收到回復信息后就進入二進制流傳輸階段,這時就可以開始發送二進制流了
等初始方將流發送完畢后把socket流關閉傳輸就完成了文件的傳輸。
注意:type為result的回復信息使用的id一定要和請求的信息id一樣。
posted @
2012-02-13 00:55 wkkyo 閱讀(8578) |
評論 (5) |
編輯 收藏
struts2使用FilterDispatcher進行url過濾,默認是所有的url都過濾,但是項目中有些url是不想用struts2進行過濾的,網上搜了不少方法
1.修改web.xml文件。
<filter-mapping>
<filter-name>struts2</filter-name>
<url-pattern>*.action</url-pattern>
</filter-mapping>
只讓過濾器對加有.action后綴的路徑有效,如果需要攔截.jsp,加上*.jsp就行了。
但是這樣如果有無后綴名的url(如/demo/)就不能過濾了
2.修改struts2核心jar中的default.properties文件
把struts.action.extension=action,,
改為struts.action.extension=action,do,jsp,
但我改了之后發現根本沒效果,不知為何
3.自定義一個繼承StrutsPrepareAndExecuteFilter的過濾器,將配置換成自己自定義的過濾器。(推薦此法)
public class ExtendStrutsFilter extends StrutsPrepareAndExecuteFilter {
@Override
public void doFilter(ServletRequest req, ServletResponse res,FilterChain chain) throws IOException, ServletException {
HttpServletRequest request = (HttpServletRequest) req;
//不過濾的url,可以不斷添加,如fck可用/fckeditor/editor/filemanager/connectors/fileupload,下面的是flex
if ("/fpms/messagebroker/amf".equals(request.getRequestURI())) {
//System.out.println("使用自定義的過濾器");
chain.doFilter(req, res);
}else{
//System.out.println("使用默認的過濾器");
super.doFilter(req, res, chain);
}
}
}
修改web.xml
<!-- sturts2過濾器 -->
<filter>
<filter-name>struts2</filter-name>
<!-- 改為自己的過濾器 -->
<filter-class>
com.filter.ExtendStrutsFilter
</filter-class>
</filter>
<filter-mapping>
<filter-name>struts2</filter-name>
<url-pattern>/*</url-pattern>
</filter-mapping>
這種方法試驗成功
posted @
2010-10-15 11:54 wkkyo 閱讀(5799) |
評論 (2) |
編輯 收藏
Hibernate在進行數據讀取時會先在緩存里找,緩存中不存在時再去數據庫查詢,合理使用hibernate緩存能夠有效的利用內存,減少物理數據庫調用的次數.
ORM緩存策略
1.事務級緩存(session level cache)
session生命周期的緩存,關閉session即消亡
2.應用級/進程級緩存(sessionFactory level cache)
某個應用中的共享緩存,多個事務可以共享,在sessionFactory層實現,所有sessionFactory創建的session可以共享.
3.分布式緩存
多個JVM共享的緩存,通過遠程機制實現緩存數據同步,任意實例修改數據,所有的JVM都要更新緩存.
Hibernate數據緩存
1.內部緩存(session level)一級緩存
是事務級的緩存,session中維護的一個Map,Map的key是包含了數據類型和id,從數據庫加載的數據都會進入Map緩存中,通過session加載數據時會先在session緩存里找,一級緩存是session的private數據,session實例消亡就清除了,在應用中就保持在一次請求的開始和結束之間.
一般由Hibernate自動維護,也支持手動維護
session.evit(Object obj) 將持久化對象從一級緩存中清除.
session.clear() 清空一級緩存
session.contains(Object obj) 判斷指定的對象是否存在于一級緩存中.
session.flush() 刷新一級緩存區的內容,使緩存與數據庫數據保持同步.
2.二級緩存(sessionFactory level)
包含了應用級和分布式的緩存,由本sessionFactory的所有session實例共享,session操作時會先查一級緩存,然后查二級緩存,最后再查物理數據庫.要使用二級緩存必須要進行配置.
適合用緩存的數據
1.不會被其他應用修改
包括直接用JDBC修改等,因為其他應用修改了數據之后hibernate并不知道,不能自動更新緩存,不過可以手動更新緩存
2.數據大小可以接受,畢竟內存資源也不多
3.數據更新頻率低(比如數據字典等常量數據)
4.可能被系統頻繁使用
5.非關鍵的數據
6.不會被并發訪問的數據
常用的二級緩存插件
EHCache org.hibernate.cache.EhCacheProvider
OSCache org.hibernate.cache.OSCacheProvider
SwarmCahe org.hibernate.cache.SwarmCacheProvider 提供了分布式
JBossCache org.hibernate.cache.TreeCacheProvider 提供了分布式
EHCache二級緩存配置方法
1.啟用二級緩存首先要在hibernate.cfg.xml配置
<hibernate-configuration>
<session-factory>
<!-- 配置二級緩存插件EHCache的Provider類-->
<property name="hibernate.cache.provider_class">
org.hibernate.cache.EhCacheProvider
</property>
<!-- 啟動"查詢緩存" -->
<property name="hibernate.cache.use_query_cache">
true
</property>
</session-factory>
</hibernate-configuration>
2.然后配置cache的配置文件ehcache.xml
<ehcache>
<!-- maxElementsInMemory為緩存對象的最大數目,
eternal設置是否永遠不過期,
timeToIdleSeconds對象處于空閑狀態的最多秒數,
timeToLiveSeconds對象處于緩存狀態的最多秒數,
overflowtodisk內存不足時是否啟用磁盤緩存 -->
<diskStore path="java.io.tmpdir"/>
<defaultCache maxElementsInMemory="10000" eternal="false" timeToIdleSeconds="300" timeToLiveSeconds="600" overflowToDisk="true"/>
</ehcache>
3.最后要在映射文件***.hbm.xml中指定實體的緩存同步策略
<?xml version="1.0" encoding='UTF-8'?>
<!DOCTYPE hibernate-mapping PUBLIC "-//Hibernate/Hibernate Mapping DTD 3.0//EN"
"http://hibernate.sourceforge.net/hibernate-mapping-3.0.dtd" >
<hibernate-mapping>
<class>
<!-- 設置該持久化類的二級緩存并發訪問策略-->
<cache usage="read-write"/>
<set name = "xxx">
<cache usage="read-only" />
</set>
</class>
</hibernate-mapping>
hibernate提供的緩存同步策略,可以在usage中設置
read-only
只讀
nonstrict-read-write
更新頻率不高
read-write
嚴格可讀寫
transactional(Ecache不支持)
事務型緩存
posted @
2010-08-22 23:22 wkkyo 閱讀(445) |
評論 (0) |
編輯 收藏