public class TcpReceive {
private static Server mserver=null;
public static void main(String[] args) throws IOException {
reserver re = new reserver();
Thread th = new Thread(re);
th.start();
}
static class reserver implements Runnable{
DatagramSocket socket=null;
public void run() {
mserver=new Server(20000000,8*1024);
mserver.getKryo().setRegistrationRequired(false);
mserver.addListener(new Listener()
{
public void received (Connection c, Object object)
{
if (object instanceof byte[])
{
String con = new String((byte[])object);
System.out.println(con);
}
}
});
try
{
mserver.bind(10086);
mserver.start();
}catch(Exception e)
{
System.out.println("Start event transfer tcp service: port="+10086);
}
System.out.println("Event transfer tcp service start.");
}
}
}