?? receivecbs.java
字號:
import java.io.IOException;
import javax.microedition.io.Connector;
import javax.microedition.midlet.MIDlet;
import javax.microedition.midlet.MIDletStateChangeException;
import javax.wireless.messaging.Message;
import javax.wireless.messaging.MessageConnection;
import javax.wireless.messaging.MessageListener;
import javax.wireless.messaging.TextMessage;
public class ReceiveCBS extends MIDlet implements MessageListener{
/** 用于接收消息 */
private MessageConnection mcbs;
public ReceiveCBS() {
super();
// TODO 自動生成構造函數存根
}
protected void startApp() throws MIDletStateChangeException {
//啟動消息監聽
try {
mcbs = (MessageConnection)Connector.open
("cbs://:1234"); //1234為小區廣播標識
//注冊消息監聽器.
mcbs.setMessageListener(this);
} catch (Exception e) {
System.out.println("不能進行小區廣播接收:" + e.toString());
}
}
protected void pauseApp() {
// TODO 自動生成方法存根
}
protected void destroyApp(boolean arg0)
throws MIDletStateChangeException {
// TODO 自動生成方法存根
}
/**
* 當有消息到達時執行該函數
*/
public void notifyIncomingMessage(MessageConnection mc) {
//在獨立的線程中接收消息
new Thread() {
public void run() {
Message msg=null;
try {
msg = mcbs.receive();
} catch (IOException e) {
//處理讀取消息時發生的錯誤
System.out.println("讀取消息時發生異常:" +
e.toString());
return;
}
//處理讀取的文本消息
if(msg == null) {
return;
}
System.out.println("讀取消息...");
if(msg instanceof TextMessage){
TextMessage tmsg = (TextMessage)msg;
System.out.println("接收到一條消息");
System.out.println(" 接收時間:" +
tmsg.getTimestamp());
System.out.println(" 消息發送方:" +
tmsg.getAddress());
System.out.println(" 消息內容:" +
tmsg.getPayloadText());
} else {
//二進制消息處理
}
}
}.start();
}
}
?? 快捷鍵說明
復制代碼
Ctrl + C
搜索代碼
Ctrl + F
全屏模式
F11
切換主題
Ctrl + Shift + D
顯示快捷鍵
?
增大字號
Ctrl + =
減小字號
Ctrl + -