QQDemo_mobile版本一

服务端：

package com;

import javax.microedition.io.*;

import java.io.*;

import javax.microedition.io.ServerSocketConnection;
import javax.microedition.lcdui.*;
import javax.microedition.midlet.MIDlet;
import javax.microedition.midlet.MIDletStateChangeException;

public class ServerSocket extends MIDlet implements Runnable, CommandListener {
	
	private Form form;
	private StringItem stri;
	private Command exitCmd,sendCmd;
	private TextField tf;
	Sends send;
	
	public ServerSocket() {
		form = new Form("serverSocket");
		stri = new StringItem("接收信息:","");
		tf = new TextField("发送信息:","",8000,0);
		exitCmd = new Command("exit",Command.EXIT,1);
		sendCmd = new Command("send",Command.SCREEN,1);
		form.append(stri);
		form.append(tf);
		form.addCommand(exitCmd);
		form.addCommand(sendCmd);
		form.setCommandListener(this);
	}

	protected void destroyApp(boolean arg0) throws MIDletStateChangeException {

	}

	protected void pauseApp() {

	}

	protected void startApp() throws MIDletStateChangeException {
			Display.getDisplay(this).setCurrent(form);
			Thread th = new Thread(this);
			th.start();
	}

	public void run() {
		ServerSocketConnection scn = null;
		SocketConnection sn = null;
		InputStream is = null;
		OutputStream os = null;
		 try {
			scn= (ServerSocketConnection)Connector.open("socket://:6000");
			sn = (SocketConnection) scn.acceptAndOpen();
			is = sn.openInputStream();
			os = sn.openOutputStream();
			
			send = new Sends(os);
			
			
			while(true){
				StringBuffer sb = new StringBuffer();
				int count = 0;
				while((count=is.read())!='\n'&&count!=-1){
					sb.append((char)count);
				}
				this.stri.setText(sb.toString());
			}
		} catch (IOException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}finally{
			try {
				is.close();
				os.close();
				sn.close();
				scn.close();
			} catch (IOException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
		}

	}

	public void commandAction(Command cmd, Displayable dis) {
			if(cmd==exitCmd){
				try {
					destroyApp(false);
					notifyDestroyed();
				} catch (MIDletStateChangeException e) {
					// TODO Auto-generated catch block
					e.printStackTrace();
				}
			}
			
			if(cmd==sendCmd){
				this.send.send(this.tf.getString());
			}
	}

}

 

客户端：

package com;

import javax.microedition.io.*;

import java.io.*;

import javax.microedition.io.ServerSocketConnection;
import javax.microedition.lcdui.*;
import javax.microedition.midlet.MIDlet;
import javax.microedition.midlet.MIDletStateChangeException;

public class ClinetSocket extends MIDlet implements Runnable, CommandListener {
 
 private Form form;
 private StringItem stri;
 private Command exitCmd,sendCmd;
 private TextField tf;
 Sends send;
 
 public ClinetSocket() {
  form = new Form("ClinetrSocket");
  stri = new StringItem("接收信息:","");
  tf = new TextField("发送信息:","",8000,0);
  exitCmd = new Command("exit",Command.EXIT,1);
  sendCmd = new Command("send",Command.SCREEN,1);
  form.append(stri);
  form.append(tf);
  form.addCommand(exitCmd);
  form.addCommand(sendCmd);
  form.setCommandListener(this);
 }

 protected void destroyApp(boolean arg0) throws MIDletStateChangeException {

 }

 protected void pauseApp() {

 }

 protected void startApp() throws MIDletStateChangeException {
   Display.getDisplay(this).setCurrent(form);
   Thread th = new Thread(this);
   th.start();
 }

 public void run() {
  SocketConnection sn = null;
  InputStream is = null;
  OutputStream os = null;
   try {
   sn = (SocketConnection)Connector.open("socket://localhost:6000");
   is = sn.openInputStream();
   os = sn.openOutputStream();
   
   send = new Sends(os);
   
   
   while(true){
    StringBuffer sb = new StringBuffer();
    int count = 0;
    while((count=is.read())!='\n'&&count!=-1){
     sb.append((char)count);
    }
    this.stri.setText(sb.toString());
   }
  } catch (IOException e) {
   // TODO Auto-generated catch block
   e.printStackTrace();
  }finally{
  
   try {
    is.close();
    os.close();
    sn.close();
   } catch (IOException e) {
    // TODO Auto-generated catch block
    e.printStackTrace();
   }
  }

 }

 public void commandAction(Command cmd, Displayable dis) {
   if(cmd==exitCmd){
    try {
     destroyApp(false);
     notifyDestroyed();
    } catch (MIDletStateChangeException e) {
     // TODO Auto-generated catch block
     e.printStackTrace();
    }
   }
   
   if(cmd==sendCmd){
    this.send.send(this.tf.getString());
   }
 }

}
发送处理：

package com;

import java.io.IOException;
import java.io.OutputStream;

public class Sends extends Thread {
 private OutputStream os;
 private String message;
 public  Sends(OutputStream os){
  this.os=os;
  this.start();
 }
 
 public synchronized void send(String msg){
  this.message=msg;
  notify();
 }
 
 public synchronized void run() {
  while(true){
   if(this.message==null){
    try {
     this.wait();
    } catch (InterruptedException e) {
     // TODO Auto-generated catch block
     e.printStackTrace();
    }
   }
   
   if(this.message==null){
    break;
   }
   
   try {
    os.write(this.message.getBytes());
    os.write("\r\n".getBytes());
   } catch (IOException e) {
    // TODO Auto-generated catch block
    e.printStackTrace();
   }
   
   this.message=null;
  }
 }
 

}
欢迎大家来加添新功能！！！！