Как то странно работает сервер....В дебаг режиме все отсылает а когда так запускаю то не присылает данные.
и не хочет выключать сервер при подачи данных "exit"
кто нить гляньте
СерверКод
public class JServer {
static String message;
static String oldmessage;
public static void main(String[] ar) throws IOException
{
Server server = new Server();
server.start();
server.bind(40012, 40013);
System.out.println("Сервер запущен!!");
Kryo kryo = server.getKryo();
kryo.register(String.class);
server.addListener(new Listener() {
public void received(Connection connection, Object object) {
if (object instanceof String) {
String mge = (String) object;
message = new String();
message = mge;
System.out.println(message);
}
}
});
while(true)
{
if (message!=oldmessage && message!=null && message!="")
{
System.out.println("Рассылка.....");
oldmessage = message;
server.sendToAllTCP(message);
if (message=="exit")
{
server.sendToAllTCP(message);
server.close();
break;
}
}
}
}
}
Клиент
Код
import java.io.IOException;
import java.util.Scanner;
import com.esotericsoftware.kryo.Kryo;
import com.esotericsoftware.kryonet.*;
public class JClient
{
public static void main(String[] ar) throws IOException
{
Scanner in = new Scanner(System.in);
System.out.println("Введите IP :");
String ip = in.next();
Client client = new Client();
client.start();
client.connect(2015, ip , 40012, 40013);
Kryo kryo = client.getKryo();
kryo.register(String.class);
client.addListener(new Listener() {
public void received(Connection connection, Object object) {
if (object instanceof String) {
String mge = (String) object;
System.out.println(mge);
}
}
});
while(true)
{
client.sendTCP(in.next());
}
}
}
