receivecbs.java

java me的一些源码,包括多媒体（声音、视频）

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();
    }
}