騎豬闖天下

J2ME隨筆,記錄成長的腳步

導(dǎo)航

<

2010年2月

>

日

一

二

三

四

五

六

31

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

1

2

3

4

5

6

7

8

9

10

11

12

13

隨筆檔案

文章檔案

統(tǒng)計

隨筆 - 47
文章 - 3
評論 - 37
引用 - 0

留言簿(3)

閱讀排行榜

評論排行榜

[J2ME]斷點(diǎn)續(xù)傳

斷點(diǎn)續(xù)傳的頭信息設(shè)置：
conn.setRequestProperty("RANGE", "bytes=" + size + "-"); //斷點(diǎn)續(xù)傳

項目中使用斷點(diǎn)續(xù)傳，頭信息的屬性按上面設(shè)置好了，但無論怎么測試，就是不能實(shí)現(xiàn)，費(fèi)了一天又一個晚上的功夫才查到問題所在，在使用斷點(diǎn)續(xù)傳的時候，頭信息的聯(lián)網(wǎng)方式設(shè)為了post，導(dǎo)致無法續(xù)傳！

實(shí)踐證明要實(shí)現(xiàn)斷點(diǎn)續(xù)傳：聯(lián)網(wǎng)方式必須使用get方式，或默認(rèn)不設(shè)置。

以下是斷點(diǎn)續(xù)傳的部分代碼：

package com.xuudoo.booking;

import java.io.DataInputStream;

import java.io.IOException;

import javax.microedition.io.Connector;

import javax.microedition.io.HttpConnection;

import javax.microedition.rms.InvalidRecordIDException;

import javax.microedition.rms.RecordEnumeration;

import javax.microedition.rms.RecordStoreException;

import javax.microedition.rms.RecordStoreNotOpenException;

import com.xuudoo.ewl.EWLScreen;

public class DownloadTool implements Runnable {

public XItem item;//當(dāng)前下載的item

public String imageName;//當(dāng)前下載的書名

public int FocusID;//當(dāng)前下載的ID

public HttpConnection conn = null;

public DataInputStream dis = null;

public RMSRecorderIfno rms;//存放下載的漫畫數(shù)據(jù)

public RMSRecorderIfno rms1;//存放下載的url和數(shù)據(jù)節(jié)點(diǎn)個數(shù)

public RMSRecorderIfno rms2; //存放廢字節(jié)長度

public DownloadTool(XItem xitem,int focusID) {

item = xitem;

imageName = xitem.itemId;

FocusID = focusID;

}

public void run() {

UIManager.isLoading = true;

try {

System.gc();

String url = "";

if (item.isResume){

downloadFileagain(url);

}else{

url = UIManager._currMgz.mgzLocate;

downloadFile(url);

}

UIManager._instance.doLoop();

do {

if (UIManager._instance.downloadurl == null)

break;

for (int i = 0; i < UIManager._instance.downloadurl.size();) {

url = (String) UIManager._instance.downloadurl.elementAt(i);

item = (XItem) UIManager._instance.downloaditem.elementAt(i);

imageName = item.itemId;

FocusID = Integer.parseInt((String) UIManager._instance.downloadid.elementAt(i));

if (item.isResume)

downloadFileagain(url);

else

downloadFile(url);

break;

}

UIManager._instance.downloadurl.removeElement(url);

UIManager._instance.downloaditem.removeElement(item);

UIManager._instance.downloadid.removeElement(Integer.toString(FocusID));

UIManager._instance.doLoop();

} while (UIManager._instance.downloadurl != null && UIManager._instance.downloadurl.size() >= 1);

} catch (Exception e) {

if(BookingMidlet.DEBUG)

e.printStackTrace();

} finally {

UIManager.isLoading = false;

UIManager._instance.doLoop();

}

public synchronized void StopDownLoadThread() {

if (conn != null) {

notify();

Close();

}

public synchronized void CloseMidlet() {

if (dis != null) {

try {

dis.close();

} catch (IOException e) {

e.printStackTrace();

}

dis = null;

}

if (conn != null) {

notify();

try {

conn.close();

} catch (IOException e) {

e.printStackTrace();

}

conn = null;

}

if (rms != null) {

rms.close();

rms = null;

}

if (rms1 != null) {

rms1.close();

rms1 = null;

}

if (rms2 != null) {

rms2.close();

rms2 = null;

}

if(UIManager._instance._percent != null)

UIManager._instance._percent = null;

}

private void Close() {

if (dis != null) {

try {

dis.close();

} catch (IOException e) {

e.printStackTrace();

}

dis = null;

}

if (conn != null) {

try {

conn.close();

} catch (IOException e) {

e.printStackTrace();

}

conn = null;

}

try {

Thread.sleep(500);

if(BookingMidlet.DEBUG)

System.out.println("-----關(guān)閉連接和RMS.");

} catch (Exception ex) {

//

}

if (rms != null) {

rms.close();

rms = null;

}

if (rms1 != null) {

rms1.close();

rms1 = null;

}

if (rms2 != null) {

rms2.close();

rms2 = null;

}

if(UIManager._instance._percent != null)

UIManager._instance._percent = null;

}

private int xcblength = 0; //整個xcb記錄個數(shù)

public void downloadFile(String url){

if (RMSRecorderIfno.exists("002_" + imageName + "_mgz"))

RMSRecorderIfno.delete("002_" + imageName + "_mgz");

rms = new RMSRecorderIfno();

rms.open("002_" + imageName + "_mgz", true);

//

rms2 = new RMSRecorderIfno();

if (RMSRecorderIfno.exists("002_" + imageName + "_byte")) {

RMSRecorderIfno.delete("002_" + imageName + "_byte");

}

rms2.open("002_" + imageName + "_byte", true);

rms1 = new RMSRecorderIfno();

rms1.open("002_" + imageName + "_url", true);

byte[] urlbyte = url.getBytes();

rms1.openWriteStream();

rms1.write(urlbyte);

rms1.addRecord(rms1.saveStreamToByteArray());

rms1.closeWriteStream();

String precentstr = "0";// 下載進(jìn)度的百分比

try {

//S40_V3版本需通過cmwap才能下載

if (!BookingMidlet.useProxy){

conn = (HttpConnection)Connector.open(url);

} else {

String remainUrl = url.substring("http://".length());

int index = remainUrl.indexOf("/");

String path = "";

if (index != -1) {

path = remainUrl.substring(index);

remainUrl = remainUrl.substring(0, index);

}

String host = "";

String port = "";

index = remainUrl.indexOf(":");

if (index != -1) {

host = remainUrl.substring(0, index);

port = remainUrl.substring(index + 1);

} else {

host = remainUrl;

port = null;

}

String proxyHost = "10.0.0.172";

String proxyPort = "80";

String cnwapUrl = "http://" + proxyHost + ":" + proxyPort + path;

conn = (HttpConnection) Connector.open(cnwapUrl);

if (port == null)

conn.setRequestProperty("X-Online-Host", host);

else

conn.setRequestProperty("X-Online-Host", host + ":" + port);

}

dis = conn.openDataInputStream();

// begin analyze db file

dis.skip(0x50L);//RMS頭 80個字節(jié)

int recNum = dis.readInt();//xcb文件的節(jié)點(diǎn)數(shù)，4個字節(jié)

rms1.openWriteStream();

rms1.write(recNum);

rms1.addRecord(rms1.saveStreamToByteArray());

rms1.closeWriteStream();

dis.skip(0x1CL);//28個字節(jié)的廢字節(jié)

for (int i = 0; i < recNum; i++) {

if (BookingMidlet.limitDownloadSpeed){

try {

Thread.sleep(1000);

} catch (Exception ex) {

//

}

EWLScreen.instance.repaint();

//16個字節(jié)是節(jié)點(diǎn)頭

dis.readInt();//4個字節(jié)的當(dāng)前節(jié)點(diǎn)的序號

dis.readInt();//4個字節(jié)的廢字節(jié)

int occupied = dis.readInt();//4個字節(jié)表示當(dāng)前節(jié)點(diǎn)所在內(nèi)存大小

int recsize = dis.readInt();//4個字節(jié)表示當(dāng)前節(jié)點(diǎn)的實(shí)際大小

byte recdata[] = new byte[recsize];

dis.readFully(recdata);

if(BookingMidlet.DEBUG)

System.out.println("-----save rms data: "+recsize);

// 以下代碼用以計算下載百分比

precentstr = "" + (100 * DownPrecent(rms)) / (recNum + 0.01);

precentstr = forMatString(precentstr);

UIManager._instance.set_percent(precentstr, FocusID);

EWLScreen.prompt2 = precentstr;

////////////////////////////////////////////////////////////////////////

rms.openWriteStream();

rms.write(recdata);

rms.addRecord(rms.saveStreamToByteArray());

rms.closeWriteStream();

//保存節(jié)點(diǎn)后面的廢字節(jié)，以便續(xù)傳時使用

int Wastebytes = occupied - recsize - 16;

rms2.openWriteStream();

rms2.write(Wastebytes);

rms2.addRecord(rms2.saveStreamToByteArray());

rms2.closeWriteStream();

dis.skip(Wastebytes); // subtract rec header

}

UIManager._instance.removeDownloadingItem(item);

UIManager._instance.openDownloaded();

UIManager._instance.insertDownloaded(item);

} catch (Exception e) {

if(BookingMidlet.DEBUG){

System.out.println("-----中斷下載。");

}

// UIManager.showAlert("下載失敗！請刪除后重新下載");

} finally {

Close();

}

public void downloadFileagain(String url){

try {

if (RMSRecorderIfno.exists("002_" + imageName + "_mgz") && !item.isResume)

RMSRecorderIfno.delete("002_" + imageName + "_mgz");

rms = new RMSRecorderIfno();

rms.open("002_" + imageName + "_mgz", true);

//

rms2 = new RMSRecorderIfno();

if (RMSRecorderIfno.exists("002_" + imageName + "_byte") && !item.isResume) {

RMSRecorderIfno.delete("002_" + imageName + "_byte");

}

rms2.open("002_" + imageName + "_byte", true);

//以下代碼用以斷點(diǎn)續(xù)傳

rms1 = new RMSRecorderIfno();

rms1.open("002_" + imageName + "_url", false);

url = setValue(rms1);

////////////////////////////////////////////////////////////////////////////

String precentstr = "0";// 下載進(jìn)度的百分比

precentstr = "" + (100 * DownPrecent(rms)) / (xcblength);

precentstr = forMatString(precentstr);

UIManager._instance.set_percent(precentstr, FocusID);

//S40_V3版本需通過cmwap才能下載

if (!BookingMidlet.useProxy){

conn = (HttpConnection)Connector.open(url);

} else {

String remainUrl = url.substring("http://".length());

int index = remainUrl.indexOf("/");

String path = "";

if (index != -1) {

path = remainUrl.substring(index);

remainUrl = remainUrl.substring(0, index);

}

String host = "";

String port = "";

index = remainUrl.indexOf(":");

if (index != -1) {

host = remainUrl.substring(0, index);

port = remainUrl.substring(index + 1);

} else {

host = remainUrl;

port = null;

}

String proxyHost = "10.0.0.172";

String proxyPort = "80";

String cnwapUrl = "http://" + proxyHost + ":" + proxyPort + path;

conn = (HttpConnection) Connector.open(cnwapUrl);

if (port == null)

conn.setRequestProperty("X-Online-Host", host);

else

conn.setRequestProperty("X-Online-Host", host + ":" + port);

}

//設(shè)置Range

int skipNum = RmsSize(rms, rms2);

if (skipNum == 112) {

dis = conn.openDataInputStream();

dis.skip(0x50L);//RMS頭 80個字節(jié)

xcblength = dis.readInt();//xcb文件的節(jié)點(diǎn)數(shù)，4個字節(jié)

rms1.openWriteStream();

rms1.write(xcblength);

rms1.setRecord(2, rms1.saveStreamToByteArray());

rms1.closeWriteStream();

dis.skip(0x1CL);//28個字節(jié)的廢字節(jié)

}else{

conn.setRequestProperty("RANGE", "bytes=" + skipNum + "-");//斷點(diǎn)續(xù)傳

dis = conn.openDataInputStream();

}

item.isResume = false;

int num = DownPrecent(rms);

for (int i = 0; i < xcblength - num; i++) {

if (BookingMidlet.limitDownloadSpeed){

try {

Thread.sleep(1000);

} catch (Exception ex) {

//

}

EWLScreen.instance.repaint();

//16個字節(jié)是節(jié)點(diǎn)頭

dis.readInt();//4個字節(jié)的當(dāng)前節(jié)點(diǎn)的序號

dis.readInt();//4個字節(jié)的廢字節(jié)

int occupied = dis.readInt();//4個字節(jié)表示當(dāng)前節(jié)點(diǎn)所在內(nèi)存大小

int recsize = dis.readInt();//4個字節(jié)表示當(dāng)前節(jié)點(diǎn)的實(shí)際大

byte recdata[] = new byte[recsize];

dis.readFully(recdata);

rms.openWriteStream();

rms.write(recdata);

rms.addRecord(rms.saveStreamToByteArray());

rms.closeWriteStream();

precentstr = "" + (100 * DownPrecent(rms)) / (xcblength);

precentstr = forMatString(precentstr);

UIManager._instance.set_percent(precentstr, FocusID);

//保存節(jié)點(diǎn)后面的廢字節(jié)，以便續(xù)傳時使用

int Wastebytes = occupied - recsize - 16;

rms2.openWriteStream();

rms2.write(Wastebytes);

rms2.addRecord(rms2.saveStreamToByteArray());

rms2.closeWriteStream();

dis.skip(Wastebytes); // subtract rec header

}

UIManager._instance.removeDownloadingItem(item);

UIManager._instance.openDownloaded();

UIManager._instance.insertDownloaded(item);

} catch (Exception e) {

if(BookingMidlet.DEBUG){

System.out.println("-----中斷下載。");

}

//UIManager.showAlert("下載失敗！請刪除后重新下載");

} finally {

Close();

}

/**

* 計算百分比

* @param str

* @return

*/

public static String forMatString(String str) {

String values;

int index = str.indexOf(".");

if(index != -1){

values = str.substring(0, index);

}else{

values = str;

}

return values;

}

/**

* 遍歷RMS，得到當(dāng)前記錄個數(shù)

* @param rms

* @return

*/

public int DownPrecent(RMSRecorderIfno rms) {

int i = 0;

try {

RecordEnumeration enu = null;

if (enu == null) {

enu = rms.rs.enumerateRecords(null, null, false);

}

while (enu.hasNextElement()) {

try {

enu.nextRecordId();

} catch (InvalidRecordIDException e) {

e.printStackTrace();

}

i++;

}

} catch (RecordStoreNotOpenException e) {

e.printStackTrace();

}

return i;

}

/**

* 遍歷RMS，計算當(dāng)前記錄的長度

* @param rms

* @param rms1

* @return

*/

public int RmsSize(RMSRecorderIfno _rms, RMSRecorderIfno _rms2) {

int i = 112;

try {

RecordEnumeration enu = null;

if (enu == null) {

enu = _rms.rs.enumerateRecords(null, null, false);

}

while (enu.hasNextElement()) {

try {

i += enu.nextRecord().length;

i += 16;

} catch (InvalidRecordIDException e) {

e.printStackTrace();

} catch (RecordStoreException e) {

e.printStackTrace();

}

} catch (RecordStoreNotOpenException e) {

e.printStackTrace();

}

i = i + sikpSize(_rms2);

return i;

}

/**

* 遍歷RMS，計算rms中各個節(jié)點(diǎn)后跳過的節(jié)點(diǎn)大小

* @param rms

* @return

*/

public int sikpSize(RMSRecorderIfno _rms2) {

int len = 0;

try {

RecordEnumeration enu = null;

if (enu == null) {

enu = _rms2.rs.enumerateRecords(null, null, false);

}

while (enu.hasNextElement()) {

try {

len += bytesToInt(enu.nextRecord());

} catch (InvalidRecordIDException e) {

e.printStackTrace();

} catch (RecordStoreException e) {

e.printStackTrace();

}

} catch (RecordStoreNotOpenException e) {

e.printStackTrace();

}

return len;

}

/**

* byte轉(zhuǎn)int

* @param bytes

* @return

*/

public static int bytesToInt(byte[] bytes) {

int result = 0;

for (int i = 0; i < bytes.length; i++) {

result <<= 8;

result |= (bytes[i] & 0xff); //此處忽略byte的符號位

}

return result;

}

private String setValue(RMSRecorderIfno rms){

String url = "";

RecordEnumeration enu = null;

if (enu == null) {

try {

enu = rms.rs.enumerateRecords(null, null, false);

} catch (RecordStoreNotOpenException e) {

e.printStackTrace();

}

int i = 0;

while (enu.hasNextElement()) {

try {

i = enu.nextRecordId();

if (i == 1) {

url = new String(rms.getRecord(i));

} else if (i == 2) {

xcblength = bytesToInt(rms.getRecord(i));

}

} catch (InvalidRecordIDException e) {

e.printStackTrace();

}

return url;

}

posted on 2010-02-25 14:58 騎豬闖天下閱讀(347) 評論(0) 編輯收藏

新用戶注冊刷新評論列表


只有注冊用戶登錄后才能發(fā)表評論。




網(wǎng)站導(dǎo)航: 博客園 IT新聞 Chat2DB C++博客博問管理