package btserver;
import btUtils.MiscFunc;
import java.nio.*;
import java.io.*;
import java.util.*;
import java.sql.*;
import org.xsocket.stream.*;
import org.apache.log4j.Logger;
public class BTServer implements IConnectHandler, IDataHandler, IDisconnectHandler
{
static Logger logger = Logger.getLogger(BTServer.class.getName());
private UserManager userMgr = null;
public BTServer()
{
logger.debug("[Init start ...]");
userMgr = UserManager.getInstance();
logger.debug("[Init success]");
}
public boolean onData(INonBlockingConnection connection) throws IOException
{
NetUser cur_gmr = userMgr.findByConnection(connection);
if(cur_gmr == null)
{
cur_gmr = new NetUser(connection, false);
logger.debug("[New connection: IP = " + connection.getRemoteAddress().getHostAddress() + "; Address = " +
connection.getRemoteAddress().getHostName() + ";]");
}
ByteBuffer[] bbuf = connection.readAvailable();
int index = 0;
byte[] buf = null;
for(int i=0; i < bbuf.length; i++)
{
buf = new byte[bbuf[i].capacity()];
for(int k=0; k < buf.length; k++)
buf[k] = bbuf[i].get();
if(cur_gmr.last_msg == null)
cur_gmr.last_msg = new NetMessage();
while( (index = cur_gmr.last_msg.createFromBuffer(buf,index)) > 0)
{
if(cur_gmr.last_msg.complete)
ProcessMsg(cur_gmr);
if(cur_gmr.last_msg == null)
cur_gmr.last_msg = new NetMessage();
}
if(cur_gmr.last_msg != null)
{
ProcessMsg(cur_gmr);
}
buf = null;
}
return true;
}
private void ProcessMsg(NetUser usr)
{
NetMessage nm = null;
Random rnd = null;
List<Object> params = null;
boolean status = false;
logger.debug("[" + usr.last_msg.type + " from " + usr.userName + "(" + usr.ID + ")]");
usr.bytes_send += usr.last_msg.body.length;
switch(usr.last_msg.type)
{
case MSGC_LOGIN:
status = userMgr.clientLogin(usr, usr.last_msg.params);
break;
case MSGC_PING:
int userID = (Integer)usr.last_msg.params.get(0);
String key = (String)usr.last_msg.params.get(1);
usr.lastPingTime = MiscFunc.getSeconds();
if(userID != usr.ID && !key.equals(usr.currentKey))
{
logger.info("Client info is wrong!; Removing client from user list");
userMgr.removeClient(usr);
try
{
usr.connection.close();
}
catch (IOException ex)
{
ex.printStackTrace();
}
}
break;
default:
break;
}
usr.last_msg.params.clear();
usr.last_msg = null;
nm = null;
}
public boolean onConnect(INonBlockingConnection connection) throws IOException
{
return true;
}
public boolean onDisconnect(INonBlockingConnection connection) throws IOException
{
NetUser player = userMgr.findByConnection(connection);
if(player != null)
{
logger.info("[Client " + player.userName + "(" + player.ID + ") disconnected]");
userMgr.removeClient(player);
}
else
{
logger.warn("[Unknown client disconnected]");
}
return true;
}
}
Клиент :
package Main;
import javax.microedition.midlet.*;
import javax.microedition.lcdui.*;
public class BTMidlet extends MIDlet implements CommandListener{
Display display = null;
BTApp game = null;
Form form = null;
TextField textField = null;
int fieldType;
public BTMidlet(){
super();
display = Display.getDisplay(this);
game = new BTApp(this);
display.setCurrent(game);
game.start();
}
public void startApp() {
}
public void pauseApp() {
}
public void destroyApp(boolean unconditional) {
notifyDestroyed();
}
public void quit(){
game.stop();
notifyDestroyed();
}
public void commandAction(Command command, Displayable displayable)
{
}
}