senddata.java

It is a MMORPG multithreading server. It can connect many clients using Java Connection socket.

package MMORPG;

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

class SendData implements Runnable
{
    private OutputStream os;
	private Vector msgVector = new Vector();
	private String data;
	private long systemTime;
	
	public SendData(OutputStream tos)
	{
	    systemTime = System.currentTimeMillis();
		os = tos;
        start();
	}

	public synchronized boolean DataAccess(String msg)
	{
		if (msg != null)
		{
			msgVector.addElement(msg);
		}
		else 
		{
//			System.out.println("check");
			if (msgVector.size() != 0 )
			{
				data = (String) msgVector.elementAt(0); 
				msgVector.removeElementAt(0);
				return true;
			}
		}
		return false;
	}

	private void start()
	{
        Thread t = new Thread(this);
        t.start();
	}

	public void run()
	{
		while(true)
		{
			try {
			Thread.sleep(200);
			} catch (Exception ex) {
			}
			if (DataAccess(null))
			{
				send();
			}
		}

	}
	
	private void send()
	{
		try {
			System.out.println("send"+data);
			os.write(data.getBytes());
			os.write("\r\n".getBytes());
		} catch (IOException ioe) {
			ioe.printStackTrace();
		}
	}

};