J2MESMS手机收发短信程序

在J2ME中（SMS）手机之间的短信收发是需要端口的，我们在发短信时一般不用写端口，在接收短信时如果发送方没有写端口默认会作为普通短信发送到手机上。
使用J2ME软件时，发送短信手机和接受短信手机的端口要一直才行收到对方发来的短信
如果接收方一端关闭了J2ME软件，一般是作为普通短信发送到接收方。

短信发送程序：

package com.mopietek;

import javax.microedition.io.Connector;
import javax.wireless.messaging.MessageConnection;
import javax.wireless.messaging.TextMessage;

public class SMSSender implements Runnable{

	private static SMSSender me = new SMSSender();
	private boolean sending = false;
	private String port = null;
	private String msgString = null;
	private String receiver = null;
	
	public SMSSender(){
		
	}
	
	public static SMSSender getInstance(){
		return me;
	}
	
	public boolean isSending(){
		return sending;
	}
	
	
	public void sendMsg(String r,String p,String m){
		if(sending) return;
		receiver = r;
		port = p;
		msgString = m;
		Thread t = new Thread(this);
		t.start();
	}
	
	public void run() {
		// TODO Auto-generated method stub
		String address = "sms://"+receiver +":"+port;
		sending = true;
		MessageConnection c = null;
		try{
           c = (MessageConnection) Connector.open(address);
           TextMessage txtmessage = (TextMessage)c.newMessage(
        	  MessageConnection.TEXT_MESSAGE);	   
           txtmessage.setAddress(address);
           txtmessage.setPayloadText(msgString);
           c.send(txtmessage);
		}catch(Exception e){e.printStackTrace();}
		if(c !=null){
			try{
				c.close();
			}catch(Exception e){
				e.printStackTrace();
			}
		}
		 sending = false;
	}

}

短信接受程序

package com.mopietek;

import javax.microedition.io.Connector;
import javax.microedition.lcdui.Command;
import javax.microedition.lcdui.CommandListener;
import javax.microedition.lcdui.Display;
import javax.microedition.lcdui.Displayable;
import javax.microedition.lcdui.Form;
import javax.microedition.lcdui.TextField;
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 SMSMIDlet extends MIDlet implements CommandListener,MessageListener,Runnable{

	private SMSSender sender = null;
	private Command sendCommand = new Command("Send",Command.SCREEN,1);
	private Command exitCommand = new Command("Exit",Command.EXIT,2);
	
	private final String port = "1234";
	private TextField numberEntry = null;
	private TextField msgEntry = null;
	private Form form = null;
	private String senderAddress=null;
	private boolean endNow = false;
	private MessageConnection c = null;
	String msgReceived = null;
	
	public SMSMIDlet(){
        
		sender = SMSSender.getInstance();
	}
	
	
	
	
	protected void destroyApp(boolean param) throws MIDletStateChangeException {
		
       try{
    	   endNow = true;
    	   c.close();
       }catch(Exception e){e.printStackTrace();}	
	}

	protected void pauseApp() {

		try{
			endNow = true;
			c.close();
		}catch(Exception e){
			e.printStackTrace();
		}
	}

	protected void startApp() throws MIDletStateChangeException {

		if(form == null){
			form = new Form("SMSMIDlet");
			numberEntry = new TextField("Connect to:",null,256,TextField.PHONENUMBER);
			msgEntry = new TextField("Message:",null,160,TextField.ANY);
			form.append(numberEntry);
			form.append(msgEntry);
			
			form.addCommand(exitCommand);
			form.addCommand(sendCommand);
			form.setCommandListener(this);
		}
		Display.getDisplay(this).setCurrent(form);
		startReceive();
	}

	public void commandAction(Command c, Displayable d) {

		if(c == exitCommand){
			if(!sender.isSending()){
				try {
					destroyApp(true);
					notifyDestroyed();
				} catch (MIDletStateChangeException e) {
					// TODO Auto-generated catch block
					e.printStackTrace();
				}
			}
			
		}else if(c == sendCommand){
			String dest = numberEntry.getString();
			String msg = msgEntry.getString();
			if(dest.length()>0){
				sender.sendMsg(dest, port, msg);
			}
		}
	}

	public void notifyIncomingMessage(MessageConnection arg0) {
		// TODO Auto-generated method stub
		
	}

	public void run() {
		// TODO Auto-generated method stub
		Message msg = null;
	    c = null;
	    endNow = false;
	    
	    try{
	    	c = (MessageConnection) Connector.open("sms://:"+port);
	    	msg = c.receive();
	    	while((msg != null)&& (!endNow)){
	    		if(msg instanceof TextMessage){
	    			msgReceived = ((TextMessage)msg).getPayloadText();
	    			Display.getDisplay(this).callSerially(new SetMessage());
	    		}
	    		msg = c.receive();
	    	}
	    }catch(Exception e){
	    	e.printStackTrace();
	    }
	}
	
	private void startReceive(){
      
		Thread t;
        t = new Thread(this);
        t.start();
	}

	class SetMessage implements Runnable{

		public void run() {
            msgEntry.setString(msgReceived);			
		}
		
	}
}