mmsreceive.java

看看如何用j2me 制作自己的短信制作和发送。 附带直接运行文件

/*
 *
 * Copyright © 2007 Sun Microsystems, Inc. All rights reserved.
 * Use is subject to license terms.
 */
package example.mms;

import java.io.IOException;

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

import javax.wireless.messaging.*;


/**
 * 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() {
	display.setCurrent(resumeScreen); 

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

    /**
     * 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()));
                    if (mpm.getTimestamp() != null) {
                        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();

                            try {
                                Image image = Image.createImage(ba, 0, ba.length);
                                content.append(buff.toString());

                                ImageItem imageItem =
                                    new ImageItem(contentLocation, image,
                                        Item.LAYOUT_NEWLINE_AFTER, contentLocation);
                                content.append(imageItem);
                            } catch (IllegalArgumentException iae) {
                                buff.append(new String(ba));

                                StringItem stringItem = new StringItem("Part", buff.toString());
                                stringItem.setLayout(Item.LAYOUT_NEWLINE_AFTER);
                                content.append(stringItem);
                            }
                        }
                    }
                }

                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)) {
                destroyApp(false);
                notifyDestroyed();
            } else if (c == Alert.DISMISS_COMMAND) {
                startApp();
            }
        } catch (Exception ex) {
            ex.printStackTrace();
        }
    }
}