В статье Reddwarf для создания Java-сервера на примере онлайн-игры «Камень-ножницы-бумага»: Сервер было описано, как сделать сервер. Но поиграть на таком сервере без клиента невозможно. Поэтому в этой статье попробуем написать простейший клиент и поэкспериментировать с сервером.
Для разработки клиента скачиваем клиентские библиотеки Reddwarf в архиве sgs-client-dist-0.10.2.zip отсюда.
Создаем проект и подключаем к нему все библиотеки из директории lib скачанного архива.
Как ни странно, но попытка написать клиента командной строки привела к более громоздкому и запутанному коду, поэтому клиент будем делать графический на Swing.
Клиентская часть нашей игры будет состоять из двух классов — клиента и GUI.
Клиент реализует интерфейс SimpleClientListener — в него приходят события подключения/отключения, и сообщения от сервера. В качестве реакции на входящие сообщения клиент будет уведомлять об этом GUI. Кроме того, вся информация о протоколе будет содержаться только в этом классе, так что он будет заведовать и отправкой сообщений.
Подключаемся к указанному серверу на порт 62964 — это порт по умолчанию для Reddwarf.
Для аутентификации будем использовать простейший (и, наверное, самый часто используемый в Reddwarf) способ аутентификации — PasswordAuthentication. Поскольку наш сервер не проверяет пароль, пароль оставляем пустым.
Код Client.java полностью
GUI представляет собой простейшую формочку с полями ввода и кнопочками:
![](https://habrastorage.org/r/w1560/storage2/e81/091/c87/e81091c87018ca42ef4551624f0e5c79.png)
Исходный код формы ClientFrame.java можно посмотреть здесь
Код класса Messages.java аналогичен такому же файлу из предыдущей статьи.
Код готов, можно запускать сервер и клиенты и смотреть, что будет.
Запускаем сервер.
Запускаем два клиента:
![](https://habrastorage.org/r/w1560/storage2/e60/34d/ff1/e6034dff1e771beb1e2dd0da81061372.png)
Логинимся с одного и другого клиента:
![](https://habrastorage.org/r/w1560/storage2/33c/be0/b96/33cbe0b96a637131e9035fe216452e8f.png)
Как видим, у обоих игроков 0 очков на счету.
Лог сервера не заставляет себя ждать: поскольку мы первый раз запустили сервер, то в базе нет ни одного игрока, происходит автоматическая регистрация игроков player1 и player2.
Жмем у одного из игроков на Play — сервер автоматически выбирает второго игрока в качестве соперника и начинается бой:
![](https://habrastorage.org/r/w1560/storage2/012/7f5/141/0127f5141513d7e8afc4ea9d032830f2.png)
По логу видно, что сервер создал новую битву. Сервер ждет ответов игроков
Игроки отвечают:
Сервер ждет окончания времени битвы и подводит итоги:
На клиенте можно увидеть результаты боя и как изменилось количество очков: выигравший получил 2 очка, проигравший — ноль.
![](https://habrastorage.org/r/w1560/storage2/337/6e4/150/3376e4150b23e15a00af47c4516ef699.png)
Для того, чтобы убедиться, что данные сохранены — отключимся клиентом, перезапустим сервер и подключимся заново игроком player2.
Подключаемся клиентом: честно заработанные 2 очка сохранились.
![](https://habrastorage.org/r/w1560/storage2/af8/40a/578/af840a578defb75bf616b8f1a828d1fa.png)
Во время перезапуска в логе могут возникать подобные сообщения (со стектрейсом):
Они появляются из-за того, что при старте сервера происходит много одновременных обращений к общим объектам сервера. Поскольку многопоточность в Reddwarf базируется на неблокирующей синхронизации, то конфликтующие транзакции отказываются и производится повторная попытка выполнения действий. Платформа настроена таким образом, что при большом количестве откатов одной и той же транзакции выводится сообщение в лог. При старте сервера эти сообщения не должны вызывать беспокойства, а вот появление подобных сообщений во время работы сервера говорит об узких местах в коде серверной логики.
Исходный код клиента и сервера выложен на code.google.com, его можно закачать с SVN:
А если вы не хотите возиться с исходниками, то скомпилированные версии клиента и сервера можно найти тут: code.google.com/p/reddwarf-rock-paper-scissors-example/downloads/list
Клиент запускается с помощью команды
Для запуска сервера файл deploy.jar необходимо скопировать в директорию sgs-server-dist-0.10.2.1/deploy/ и выполнить команду запуска сервера:
Спасибо за внимание. Буду рад любой конструктивной критике.
Подготовка к работе
Для разработки клиента скачиваем клиентские библиотеки Reddwarf в архиве sgs-client-dist-0.10.2.zip отсюда.
Создаем проект и подключаем к нему все библиотеки из директории lib скачанного архива.
Коротко о клиенте
Как ни странно, но попытка написать клиента командной строки привела к более громоздкому и запутанному коду, поэтому клиент будем делать графический на Swing.
Клиентская часть нашей игры будет состоять из двух классов — клиента и GUI.
Клиент реализует интерфейс SimpleClientListener — в него приходят события подключения/отключения, и сообщения от сервера. В качестве реакции на входящие сообщения клиент будет уведомлять об этом GUI. Кроме того, вся информация о протоколе будет содержаться только в этом классе, так что он будет заведовать и отправкой сообщений.
Подключение и аутентификация
Подключаемся к указанному серверу на порт 62964 — это порт по умолчанию для Reddwarf.
Для аутентификации будем использовать простейший (и, наверное, самый часто используемый в Reddwarf) способ аутентификации — PasswordAuthentication. Поскольку наш сервер не проверяет пароль, пароль оставляем пустым.
Код Client.java полностью
public class Client implements SimpleClientListener {
private SimpleClient simpleClient;
private final String host;
private final String username;
public static final String DEFAULT_PORT = "62964";
private final ClientFrame frame;
public Client(String host, String username, ClientFrame frame) {
this.host = host;
this.username = username;
this.frame = frame;
simpleClient = new SimpleClient(this);
}
@Override
public PasswordAuthentication getPasswordAuthentication() {
return new PasswordAuthentication(username, new char[]{});
}
@Override
public void loggedIn() {
frame.loggedIn();
}
@Override
public void loginFailed(String s) {
frame.setStatus("login failed " + username+": "+s);
}
@Override
public void receivedMessage(ByteBuffer packet) {
String text = Messages.decodeString(packet);
if (text.startsWith("SCORE")) {
frame.setScore(text);
} else if (text.startsWith("BATTLE")) {
frame.startBattle(text);
} else if (text.startsWith("DRAW")) {
frame.setBattleResult(text);
} else if (text.startsWith("WON")) {
frame.setBattleResult(text);
} else if (text.startsWith("LOST")) {
frame.setBattleResult(text);
} else if (text.startsWith("ERROR")) {
frame.setStatus(text);
}
}
public void login() {
try {
Properties connectProps = new Properties();
connectProps.put("host", host);
connectProps.put("port", DEFAULT_PORT);
simpleClient.login(connectProps);
} catch (Exception e) {
e.printStackTrace();
disconnected(false, e.getMessage());
}
}
public void play() {
try {
simpleClient.send(Messages.encodeString("PLAY"));
} catch (IOException e) {
e.printStackTrace();
}
}
public void answer(String text) {
try {
simpleClient.send(Messages.encodeString(text));
} catch (IOException e) {
e.printStackTrace();
}
}
}
Интерфейс пользователя
GUI представляет собой простейшую формочку с полями ввода и кнопочками:
![](https://habrastorage.org/storage2/e81/091/c87/e81091c87018ca42ef4551624f0e5c79.png)
Исходный код формы ClientFrame.java можно посмотреть здесь
Код класса Messages.java аналогичен такому же файлу из предыдущей статьи.
Ура, запускаем!
Код готов, можно запускать сервер и клиенты и смотреть, что будет.
Запускаем сервер.
мар 03, 2012 6:53:29 PM com.sun.sgs.impl.kernel.Kernel <init>
INFO: The Kernel is ready, version: 0.10.2.1
мар 03, 2012 6:53:29 PM com.sun.sgs.impl.service.data.store.DataStoreImpl <init>
INFO: Creating database directory : C:\sgs-server-dist-0.10.2.1\data\dsdb
мар 03, 2012 6:53:29 PM com.sun.sgs.impl.service.watchdog.WatchdogServerImpl registerNode
INFO: node:com.sun.sgs.impl.service.watchdog.NodeImpl[1,health:GREEN,backup:(none)]@black registered
мар 03, 2012 6:53:30 PM hello.reddwarf.server.Server initialize
INFO: Starting new Rock-Paper-Scissors Server. Initialized database.
мар 03, 2012 6:53:30 PM com.sun.sgs.impl.kernel.Kernel startApplication
INFO: RockPaperScissors: application is ready
мар 03, 2012 6:53:30 PM hello.reddwarf.server.OnlineLoggerTask run
INFO: Online: 0
Запускаем два клиента:
![](https://habrastorage.org/storage2/516/0a1/4c8/5160a14c85f5086273d153f35013539e.png)
![](https://habrastorage.org/storage2/e60/34d/ff1/e6034dff1e771beb1e2dd0da81061372.png)
Логинимся с одного и другого клиента:
![](https://habrastorage.org/storage2/4c9/3dc/4c4/4c93dc4c49fb297dc04c3c1f1a3a89a6.png)
![](https://habrastorage.org/storage2/33c/be0/b96/33cbe0b96a637131e9035fe216452e8f.png)
Как видим, у обоих игроков 0 очков на счету.
Лог сервера не заставляет себя ждать: поскольку мы первый раз запустили сервер, то в базе нет ни одного игрока, происходит автоматическая регистрация игроков player1 и player2.
мар 03, 2012 6:53:47 PM hello.reddwarf.server.Server loggedIn
INFO: Client login: player2
мар 03, 2012 6:53:47 PM hello.reddwarf.server.Server loadOrRegister
INFO: Registering new player player2
мар 03, 2012 6:53:48 PM hello.reddwarf.server.Server loggedIn
INFO: Client login: player1
мар 03, 2012 6:53:48 PM hello.reddwarf.server.Server loadOrRegister
INFO: Registering new player player1
мар 03, 2012 6:53:50 PM hello.reddwarf.server.OnlineLoggerTask run
INFO: Online: 2
Жмем у одного из игроков на Play — сервер автоматически выбирает второго игрока в качестве соперника и начинается бой:
![](https://habrastorage.org/storage2/e40/39d/1ba/e4039d1ba763a7ddfea84960aff0c955.png)
![](https://habrastorage.org/storage2/012/7f5/141/0127f5141513d7e8afc4ea9d032830f2.png)
По логу видно, что сервер создал новую битву. Сервер ждет ответов игроков
мар 03, 2012 6:53:54 PM hello.reddwarf.server.Player play
INFO: Choosing enemy for player1
мар 03, 2012 6:53:54 PM hello.reddwarf.server.Battle <init>
INFO: Created Battle{2} for {player1} and {player2}
мар 03, 2012 6:53:54 PM hello.reddwarf.server.Battle start
INFO: Started Battle{2}
Игроки отвечают:
мар 03, 2012 6:53:56 PM hello.reddwarf.server.Battle answer
INFO: Battle{2} Player {player1} answer ROCK
мар 03, 2012 6:53:57 PM hello.reddwarf.server.Battle answer
INFO: Battle{2} Player {player2} answer PAPER
Сервер ждет окончания времени битвы и подводит итоги:
мар 03, 2012 6:53:59 PM hello.reddwarf.server.Battle finish
INFO: Battle{2} finished. Answers: {player1}->ROCK {player2}->PAPER
На клиенте можно увидеть результаты боя и как изменилось количество очков: выигравший получил 2 очка, проигравший — ноль.
![](https://habrastorage.org/storage2/3a4/3ab/798/3a43ab798598761f600b4b248cb38cf5.png)
![](https://habrastorage.org/storage2/337/6e4/150/3376e4150b23e15a00af47c4516ef699.png)
Для того, чтобы убедиться, что данные сохранены — отключимся клиентом, перезапустим сервер и подключимся заново игроком player2.
java -jar bin/sgs-stop.jar
java -jar bin/sgs-boot.jar
Подключаемся клиентом: честно заработанные 2 очка сохранились.
![](https://habrastorage.org/storage2/4fc/b99/391/4fcb99391ec5c431d88e9e33b84748c7.png)
![](https://habrastorage.org/storage2/af8/40a/578/af840a578defb75bf616b8f1a828d1fa.png)
Во время перезапуска в логе могут возникать подобные сообщения (со стектрейсом):
WARNING: Task has been retried 25 times: com.sun.sgs.impl.service.session.ClientSessionServiceImpl$RemoveNodeSpecificDataTask[owner:app:RockPaperScissors]
WARNING: Task has been retried 25 times: com.sun.sgs.impl.service.channel.ChannelServiceImpl$RemoveChannelServerProxyTask[owner:app:RockPaperScissors]
WARNING: Task has been retried 50 times: com.sun.sgs.impl.service.session.ClientSessionServiceImpl$RemoveNodeSpecificDataTask[owner:app:RockPaperScissors]
WARNING: Task has been retried 50 times: com.sun.sgs.impl.service.channel.ChannelServiceImpl$RemoveChannelServerProxyTask[owner:app:RockPaperScissors]
WARNING: Task has been retried 75 times: com.sun.sgs.impl.service.session.ClientSessionServiceImpl$RemoveNodeSpecificDataTask[owner:app:RockPaperScissors]
WARNING: Task has been retried 75 times: com.sun.sgs.impl.service.channel.ChannelServiceImpl$RemoveChannelServerProxyTask[owner:app:RockPaperScissors]
Они появляются из-за того, что при старте сервера происходит много одновременных обращений к общим объектам сервера. Поскольку многопоточность в Reddwarf базируется на неблокирующей синхронизации, то конфликтующие транзакции отказываются и производится повторная попытка выполнения действий. Платформа настроена таким образом, что при большом количестве откатов одной и той же транзакции выводится сообщение в лог. При старте сервера эти сообщения не должны вызывать беспокойства, а вот появление подобных сообщений во время работы сервера говорит об узких местах в коде серверной логики.
Исходный код клиента и сервера выложен на code.google.com, его можно закачать с SVN:
svn checkout http://reddwarf-rock-paper-scissors-example.googlecode.com/svn/trunk/ reddwarf-rock-paper-scissors-example-read-only
А если вы не хотите возиться с исходниками, то скомпилированные версии клиента и сервера можно найти тут: code.google.com/p/reddwarf-rock-paper-scissors-example/downloads/list
Клиент запускается с помощью команды
java -jar HelloReddwarfClient.jar
Для запуска сервера файл deploy.jar необходимо скопировать в директорию sgs-server-dist-0.10.2.1/deploy/ и выполнить команду запуска сервера:
java -jar bin/sgs-boot.jar
Спасибо за внимание. Буду рад любой конструктивной критике.