开发工具:
文件大小: 4kb
下载次数: 0
上传时间: 2010-06-15
详细说明： import javax.microedition.midlet.*; import javax.microedition.io.*; import javax.microedition.lcdui.*; import javax.wireless.messaging.*; import java.io.IOException; public class MyCBSReceiveMidlet extends MIDlet implements CommandListener, Runnable, MessageListener { Command exitCommand = new Command("退出", Command.EXIT, 2); Alert waiting; Display display; Thread thread; String[] connections; boolean done; String cbsMessageID; MessageConnection cbsconn; Messa ge msg; Alert receivedMessage; public MyCBSReceiveMidlet() { cbsMessageID = getAppProperty("CBS-Message-Identifier"); display = Display.getDisplay(this); waiting = new Alert("小区广播消息接收演示", null, null, AlertType.INFO); waiting.addCommand(exitCommand); waiting.setCommandListener(this); waiting.setTimeout(Alert.FOREVER); receivedMessage = new Alert("接收到的小区广播消息", null, null, AlertType.INFO); receivedMessage.setTimeout(Alert.FOREVER); receivedMessage.addCommand(exitCommand); receivedMessage.setCommandListener(this); } public void startApp() { /** CBS connection to be read. */ String cbsConnection = "cbs://:" + cbsMessageID; /** Open the message connection. */ if (cbsconn == null) { try { cbsconn = (MessageConnection) Connector.open(cbsConnection); cbsconn.setMessageListener(this); } catch (IOException ioe) { ioe.printStackTrace(); } } display.setCurrent(waiting); /** Initialize the text if we were started manually. */ connections = PushRegistry.listConnections(true); if (connections == null || connections.length == 0) { waiting.setString("等待来自 " + cbsMessageID + "的广播消息..."); } else { done = false; thread = new Thread(this); thread.start(); } } public void notifyIncomingMessage(MessageConnection conn) { if (thread == null) { done = false; thread = new Thread(this); thread.start(); } } public void run() { try { while (!done) { msg = cbsconn.receive(); if (msg != null) { if (msg instanceof TextMessage) { receivedMessage.setString( ((TextMessage)msg).getPayloadText()); } else { StringBuffer buf = new StringBuffer(); byte[] data = ((BinaryMessage)msg).getPayloadData(); for (int i = 0; i < data.length; i++) { buf.append(Integer.toHexString((int) data[i])); buf.append(' '); } receivedMessage.setString(buf.toString()); } display.setCurrent(receivedMessage); } } cbsconn.close(); } catch (IOException e) { // e.printStackTrace(); } } public void pauseApp() { done = true; thread = null; } public void destroyApp(boolean unconditional) { done = true; thread = null; if (cbsconn != null) { try { cbsconn.close(); } catch (IOException e) { // Ignore any errors on shutdown } } } public void commandAction(Command c, Displayable s) { try { if (c == exitCommand || c == Alert.DISMISS_COMMAND) { destroyApp(false); notifyDestroyed(); } } catch (Exception ex) { ex.printStackTrace(); } } } ...展开收缩
(系统自动生成,下载前可以参看下载内容)
下载文件列表
相关说明
- 本站资源为会员上传分享交流与学习,如有侵犯您的权益,请联系我们删除.
- 本站是交换下载平台，提供交流渠道，下载内容来自于网络，除下载问题外，其它问题请自行百度。
- 本站已设置防盗链，请勿用迅雷、QQ旋风等多线程下载软件下载资源，下载后用WinRAR最新版进行解压.
- 如果您发现内容无法下载，请稍后再次尝试；或者到消费记录里找到下载记录反馈给我们.
- 下载后发现下载的内容跟说明不相乎，请到消费记录里找到下载记录反馈给我们，经确认后退回积分.
- 如下载前有疑问，可以通过点击"提供者"的名字，查看对方的联系方式，联系对方咨询.
