mmsreceive.java

实现 WMA 消息传送 (SMS、CBS、MMS) 的一组 MIDlet 需要：MIDP 2.0、Wireless Messaging API 2.0 (WMA 2.0)

/*
 * @(#)MMSReceive.java	1.9 04/04/19
 *
 * Copyright (c) 2004 Sun Microsystems, Inc.  All rights reserved.
 * Use is subject to license terms
 */

package example.mms;

import javax.microedition.midlet.*;
import javax.microedition.io.*;
import javax.microedition.lcdui.*;
import javax.wireless.messaging.*;

import java.io.IOException;

/**
 * An example MIDlet displays text from an MMS MessageConnection
 */
public class MMSReceive extends MIDlet
    implements CommandListener, Runnable, MessageListener {

    /** user interface command for indicating Exit request. */
    private static final Command CMD_EXIT  =
	new Command("Exit", Command.EXIT, 2);
    /** user interface text box for the contents of the fetched URL. */
    private Form content;
    /** current display. */
    private Display display;
    /** instance of a thread for asynchronous networking and user interface. */
    private Thread thread;
    /** Connections detected at start up. */
    private String[] connections;
    /** Flag to signal end of processing. */
    private boolean done;
    /** The applicationID on which we listen for MMS messages */
    private String appID;
    /** MMS message connection for inbound text messages. */
    private MessageConnection mmsconn;
    /** Current message read from the network. */
    private Message msg;
    /** Address of the message's sender */
    private String senderAddress;
    /** Alert that is displayed when replying */
    private Alert sendingMessageAlert;
    /** The screen to display when we return from being paused */
    private Displayable resumeScreen;
    /** The subject of the message received */
    private String subject;
    /** The text of the received message */
    private String contents;

    /**
     * Initialize the MIDlet with the current display object and
     * graphical components.
     */
    public MMSReceive() {
        appID = getAppProperty("MMS-ApplicationID");

        display = Display.getDisplay(this);

        content = new Form("MMS Receive");
        content.addCommand(CMD_EXIT);
        content.setCommandListener(this);
        content.append("Receiving...");

        sendingMessageAlert = new Alert("MMS", null, null, AlertType.INFO);
        sendingMessageAlert.setTimeout(5000);
        sendingMessageAlert.setCommandListener(this);

        resumeScreen = content;
    }

    /**
     * Start creates the thread to do the MessageConnection receive
     * text.
     * It should return immediately to keep the dispatcher
     * from hanging.
     */
    public void startApp() {
        /** MMS connection to be read. */
        String mmsConnection = "mms://:" + appID;
        /** Open the message connection. */
        if (mmsconn == null) {
            try {
                mmsconn = (MessageConnection) Connector.open(mmsConnection);
                mmsconn.setMessageListener(this);
            } catch (IOException ioe) {
                ioe.printStackTrace();
            }
        }

        /** Initialize the text if we were started manually. */
        connections = PushRegistry.listConnections(true);
        if (connections == null || connections.length == 0) {
            content.deleteAll();
            content.append("Waiting for MMS on applicationID " + appID + "...");
        }
        done = false;
        thread = new Thread(this);
        thread.start();

        display.setCurrent(resumeScreen);
    }

    /**
     * Notification that a message arrived.
     * @param conn the connection with messages available
     */
    public void notifyIncomingMessage(MessageConnection conn) {
        if (thread == null && !done) {
            thread = new Thread(this);
            thread.start();
        }
    }

    /** Message reading thread. */
    public void run() {
        /** Check for mms connection. */
        try {
            msg = mmsconn.receive();
            if (msg != null) {
                senderAddress = msg.getAddress();
                content.deleteAll();
                String titleStr = senderAddress.substring(6);
                int colonPos = titleStr.indexOf(":");
                if (colonPos != -1) {
                    titleStr = titleStr.substring(0, colonPos);
                }
                content.setTitle("From: " + titleStr);
                if (msg instanceof MultipartMessage) {
                    MultipartMessage mpm = (MultipartMessage)msg;
                    StringBuffer buff = new StringBuffer("Subject: ");
                    buff.append((subject = mpm.getSubject()));
                    buff.append("\nDate: ");
                    buff.append(mpm.getTimestamp().toString());
                    buff.append("\nContent:");
                    StringItem messageItem = new StringItem("Message",
							    buff.toString());
                    messageItem.setLayout(Item.LAYOUT_NEWLINE_AFTER);
                    content.append(messageItem);
                    MessagePart[] parts = mpm.getMessageParts();
                    if (parts != null) {
                        for (int i = 0; i < parts.length; i++) {
                            buff = new StringBuffer();
                            MessagePart mp = parts[i];
                            buff.append("Content-Type: ");
                            String mimeType = mp.getMIMEType();
                            buff.append(mimeType);
                            String contentLocation = mp.getContentLocation();
                            buff.append("\nContent:\n");
                            byte[] ba = mp.getContent();
                            if (mimeType.equals("image/png")) {
                                content.append(buff.toString());
                                Image img = Image.createImage(ba, 0, ba.length);
                                ImageItem ii = new ImageItem(contentLocation,
                                        img, Item.LAYOUT_NEWLINE_AFTER, 
                                        contentLocation);
                                content.append(ii);
                            } else {
                                buff.append(new String(ba));
                                StringItem si = new StringItem(
				        "Part", buff.toString());
                                si.setLayout(Item.LAYOUT_NEWLINE_AFTER);
                                content.append(si);
                            }
                        }
                    }
                }
                display.setCurrent(content);
            }
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
    /**
     * Pause signals the thread to stop by clearing the thread field.
     * If stopped before done with the iterations it will
     * be restarted from scratch later.
     */
    public void pauseApp() {
        done = true;
        thread = null;
        resumeScreen = display.getCurrent();
    }

    /**
     * Destroy must cleanup everything.  The thread is signaled
     * to stop and no result is produced.
     * @param unconditional true if a forced shutdown was requested
     */
    public void destroyApp(boolean unconditional) {
        done = true;
        thread = null;
        if (mmsconn != null) {
            try {
                mmsconn.close();
            } catch (IOException e) {
                // Ignore any errors on shutdown
            }
        }
    }

    /**
     * Respond to commands, including exit
     * @param c user interface command requested
     * @param s screen object initiating the request
     */
    public void commandAction(Command c, Displayable s) {
        try {
            if (c == CMD_EXIT || c == Alert.DISMISS_COMMAND) {
                destroyApp(false);
                notifyDestroyed();
            }
        } catch (Exception ex) {
            ex.printStackTrace();
        }
    }
}