recvdata.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 RecvData implements Runnable
{
    private InputStream is;
	private Vector msgVector = new Vector();
	public String data;
	private long systemTime;
	
	public RecvData(InputStream tis)
	{
	    systemTime = System.currentTimeMillis();
		is = tis;
        start();
	}

	public synchronized boolean DataAccess(String msg)
	{
		if (msg != null)
		{
			msgVector.addElement(msg);
			System.out.println("RECV"+msg);
		}
		else 
		{
			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()
	{
		try {

			while(true)
			{
				StringBuffer sb = new StringBuffer();
				int c = 0;

				while (((c = is.read()) != '\n') && (c != -1)) {
					sb.append((char) c);
				}

				if (c == -1) {
					break;
				}

				DataAccess(sb.toString());
			}
		} catch (IOException e) {
		}

	}
	

};