В статье Reddwarf для создания Java-сервера на примере онлайн-игры «Камень-ножницы-бумага»: Сервер было описано, как сделать сервер. Но поиграть на таком сервере без клиента невозможно. Поэтому в этой статье попробуем написать клиент и поэкспериментировать с сервером.
Подготовка к работе
Для разработки клиента скачиваем клиентские библиотеки Reddwarf в архиве sgs-client-dist-0.10.2.zip отсюда.
Создаем проект и подключаем к нему все библиотеки из директории lib скачанного архива.
Коротко о клиенте
Клиентская часть нашей игры будет состоять из двух классов — клиента и GUI.
Клиент реализует интерфейс SimpleClientListener — в него приходят события подключения/отключения, и сообщения от сервера. В качестве реакции на входящие сообщения клиент будет уведомлять об этом GUI. Кроме того, вся информация о протоколе будет содержаться только в этом классе, так что он будет заведовать и отправкой сообщений.
Подключение и аутентификация
Подключаемся к указанному серверу на порт 62964 — это порт по умолчанию для Reddwarf.
Для аутентификации будем использовать простейший (и, наверное, самый часто используемый в Reddwarf) способ аутентификации — PasswordAuthentication. Поскольку наш сервер не проверяет пароль, пароль оставляем пустым.
package hello.reddwarf.client; import com.sun.sgs.client.ClientChannel; import com.sun.sgs.client.ClientChannelListener; import com.sun.sgs.client.simple.SimpleClient; import com.sun.sgs.client.simple.SimpleClientListener; import hello.reddwarf.Messages; import java.io.IOException; import java.net.PasswordAuthentication; import java.nio.ByteBuffer; import java.util.Properties; 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 ClientChannelListener joinedChannel(ClientChannel clientChannel) { return null; } @Override public void receivedMessage(ByteBuffer packet) { String text = Messages.decodeString(packet); if (text.startsWith("SCORE")) { frame.setScore(text); } else 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 представляет собой простейшую формочку на Swing с полями ввода и кнопочками:
package hello.reddwarf.client; import sun.awt.VerticalBagLayout; import javax.swing.*; import java.awt.*; import java.awt.event.ActionEvent; import java.awt.event.ActionListener; public class ClientFrame extends JFrame { private JTextField usernameField; private JLabel scoreLabel; private JButton loginButton; private JButton playButton; private JLabel statusLabel; private JButton rockButton; private JButton paperButton; private JButton scissorsButton; private Client client; public static void main(String[] args) { new ClientFrame("RPS").setVisible(true); } protected ClientFrame(String title) { super(title); Container c = getContentPane(); c.setLayout(new GridLayout(10,1)); c.add(new JLabel("Username:")); c.add(usernameField = new JTextField("player"+Math.round(Math.random()*10))); c.add(scoreLabel = new JLabel("SCORE")); c.add(loginButton = new JButton("Log in")); c.add(playButton = new JButton("Play!")); c.add(statusLabel = new JLabel("Status")); c.add(rockButton = new JButton("Rock")); c.add(paperButton = new JButton("Paper")); c.add(scissorsButton = new JButton("Scissors")); loginButton.setEnabled(true); playButton.setEnabled(false); rockButton.setEnabled(false); paperButton.setEnabled(false); scissorsButton.setEnabled(false); setSize(320, 240); setDefaultCloseOperation(DISPOSE_ON_CLOSE); setVisible(true); loginButton.addActionListener(new ActionListener() { @Override public void actionPerformed(ActionEvent e) { setStatus("Logging in..."); client = new Client("localhost", usernameField.getText(), ClientFrame.this); client.login(); } }); playButton.addActionListener(new ActionListener() { @Override public void actionPerformed(ActionEvent e) { setStatus("Playing..."); client.play(); } }); rockButton.addActionListener(new SendActionListener("ROCK")); paperButton.addActionListener(new SendActionListener("PAPER")); scissorsButton.addActionListener(new SendActionListener("SCISSORS")); } public void setStatus(String text) { statusLabel.setText(text); } public void loggedIn() { setStatus("Logged in!"); loginButton.setEnabled(false); playButton.setEnabled(true); } public void setScore(String text) { scoreLabel.setText(text); } public void startBattle(String text) { setStatus(text); playButton.setEnabled(false); rockButton.setEnabled(true); paperButton.setEnabled(true); scissorsButton.setEnabled(true); } public void setBattleResult(String text) { setStatus(text); playButton.setEnabled(true); rockButton.setEnabled(false); paperButton.setEnabled(false); scissorsButton.setEnabled(false); } private class SendActionListener implements ActionListener { private final String text; public SendActionListener(String text) { this.text = text; } @Override public void actionPerformed(ActionEvent e) { client.answer(text); rockButton.setEnabled(false); paperButton.setEnabled(false); scissorsButton.setEnabled(false); } } } Код класса Messages берется из предыдущей статьи.
Ура, запускаем!
Ну вот, код и готов. Можно запускать сервер и клиенты и смотреть, что будет.
Запускаем сервер.
мар 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.1datadsdb мар 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 Запускаем два клиента:
Логинимся с одного и другого клиента:
Как видим, у обоих игроков 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 — сервер автоматически выбирает второго игрока в качестве соперника и начинается бой:
По логу видно, что сервер создал новую битву. Сервер ждет ответов игроков
мар 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 очка, проигравший — ноль.
Для того, чтобы убедиться, что данные сохранены — отключимся клиентом, перезапустим сервер и подключимся заново игроком player2.
java -jar bin/sgs-stop.jar java -jar bin/sgs-boot.jar Подключаемся клиентом: честно заработанные 2 очка сохранились.
Во время перезапуска в логе могут возникать подобные сообщения (со стектрейсом):
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
Спасибо за внимание. Буду рад любой конструктивной критике.
Автор: dvb
