👏 🔊 🐥 Google Play用のゲームの作成方法について ❄️ 📒 ◼️

Google Playのステッカーの作成方法について

長い間、私は自分の知識をコミュニティと共有することを考えていました。最初は、天体物理学やGTRについて何かを書きたかったのですが、それでも私は専門的に扱っているその主題分野について書く方が正しいと判断しました。そのため、Android向けゲームアプリケーションの作成プロセスと実装の微妙な点（設計から公開、アプリ内購入まで）を詳細に説明しようとします。

はじめに

私は最初のクラスからプログラミングに従事し、サンクトペテルブルク州立工科大学の応用数学を卒業しました。最近（約1年前）、モバイルプラットフォームの開発を発見しました。それが何で、何で食べられるのかが面白くなってきました。現在、友人/同僚のチームでいくつかのプロジェクトを開発していますが、最初の経験について書きたいと思います。そのような経験は、ゲームアプリケーション-「ステッカー」（私は誰ですか？）を作成することでした。

これらはどのようなステッカーですか？

知らない人のために-私は説明します。ステッカー-これはこのようなテーブルゲームで、各プレイヤーは額に有名なキャラクターがいる紙を1枚ずつ受け取ります（プレイするキャラクターは互いに登場します）。各参加者の目標は、自分が推測したキャラクターを推測することです。

ゲームプレイは、質問の連続的なyes / noタスクであり、他のプレイヤーからそれらへの回答を受け取ります。

いくつかの理由により、ステッカーが選ばれました。

まず、市場に類似物が見つかりませんでした（これは、説明したテーブルゲームのルールの実装を指します）。

第二に、私は非常に時間がかからないものを書きたかった。

第三に、このゲームは私たちのサークルで非常に人気があり、おそらく誰かがそれを実際にプレイしたいと思うと思いました。

開発プロセス

問題の声明

タスクは非常に明確に形成されました。ユーザーが次の機能を使用できるようにするクライアント/サーバーアプリケーションを実装する必要があります。

独自のアカウントを作成する
自分のアカウントを使用した認証
プレイヤーランキングを見る
ゲームルームを作成する
ゲームルームへの入り口
ゲームプレイ参加

ゲームプレイは相変化です：

質問フェーズ
投票フェーズ

UIデザイン

幸いなことに、私の妻はデザイナーであり、パレット、要素の配置、その他のデザイナーのものを選択することに実際に参加する必要はありませんでした。ゲームがプレーヤーに提供する必要がある機能の分析に基づいて、ゲームの状態（アクティビティ）の数と各ゲームの状態に必要なコントロールを決定しました。

メインメニュー
- 認証
- 登録
- プレーヤーの評価へのアクセス
プレイヤーの評価
- メインメニューに戻ります。
部屋リスト
- 部屋への入り口
- 自分の部屋を作成する
- メインメニューに移動します
現在の部屋
- 部屋を出る
ゲーム状態番号1：入力質問
- 質問を入力する
- 質問の歴史への移行
- 回答入力に移動
- メインメニューに移動します
ゲームの状態No. 2：質問の履歴を表示する
- 質問の入力に移動
- 回答入力に移動
- メインメニューに移動します
ゲーム状態No. 3：入力応答
- 応答入力
- 質問の入力に移動
- 質問の歴史への移行
- メインメニューに移動します
ゲームの状態No. 4：投票
- 音声入力
- メインメニューに移動します
勝利
- メインメニューに移動します
倒す
- ウィキペディアに移動（キャラクターページへ）
- メインメニューに移動します

状態遷移図

DBデザイン

ゲーム内にどのゲーム状態とオブジェクトが存在するかが明らかになったらすぐに、データベースの観点からそれらを形式化することに進みました。

そのため、次の表が必要です。

ユーザーすべてのユーザーに関する情報を格納するテーブル
ゲームすべての部屋に関する情報を格納するテーブル
キャラクター。すべてのキャラクターに関する情報を保存するテーブル
質問。彼が作ったキャラクターに関するユーザーの質問を保存するテーブル
回答ユーザーの応答が保存されるテーブル

ゲームの初期バージョンにはこれらのテーブルしかありませんでしたが、ゲームが開発され、新しいテーブルが追加されました。残りのテーブルについては説明しません。そうしないと、ナレーションが非常に長くなります。すべてのテーブルはデータベースダイアグラムに表示されますが、テーブルが存在してもこれ以上の議論を妨げることはありません。

データベーススキーマ

テーブル間の関係は数回（いわばアジャイル）変更されましたが、最終的には次のようになりました。

各ユーザーは1人のキャラクターに関連付けることができます。
各ユーザーは1つの部屋にしか入室できません。
各質問は1人のユーザーのみが質問できます。
各質問は、1人のキャラクターにのみ関連付けることができます。
各質問は1つのゲーム内でのみ質問できます。
各回答は1人のユーザーのみが指定できます。
各回答は1つの質問にのみ与えることができます。

そして、データの正規化はどこにありますか？

重複した通信は、DBMSの負荷を軽減するためにのみ必要であり、ゲームの最初のバージョンからはほど遠いように見えました。テーブルの数の増加に伴い、特定のデータサンプルに対して実行する必要のある集計の数が増加しました。

アプリケーションレベル

最後に、ソフトウェアの実装に到達しました。だから、私は最も一般的な言葉から始めます。プロジェクト全体は4つのモジュールで構成されています。

ベンタ。便利なユーティリティをコンパイルするライブラリ
プロトコル。相互作用プロトコルの説明を含むライブラリ
サーバーアプリケーションサーバー
クライアントアプリケーションのクライアント側

プロジェクト概要

ベンタ図書館

私は車輪を再発明するのが好きで、サードパーティのライブラリのごまかしが嫌いなので（そう、多くの退屈なプログラマーの古典的な問題）、私は自分で何かを書くことにしました。私はこのライブラリを長い間書いており、私にとって多くの有用なユーティリティが含まれています（データベース、クライアント/サーバー相互作用、アクター、数学、暗号化など）。

この記事では、このライブラリのネットワーク部分についてお話したいと思います。私は、リクエストと回答があるオブジェクトをシリアライズ/デシリアライズすることにより、クライアントとサーバー間の相互作用を実装することにしました。 Messageオブジェクトは、転送される基本情報単位です（もちろん、ライブラリレベルで）。

「Message.java」

package com.gesoftware.venta.network.model; import com.gesoftware.venta.utility.CompressionUtility; import java.nio.charset.Charset; import java.io.Serializable; import java.util.Arrays; /* * * Message class definition * */ public final class Message implements Serializable { /* Time */ private final long m_Timestamp; /* Message data */ private final byte[] m_Data; /* * * METHOD: Message class constructor * PARAM: [IN] data - bytes array data * AUTHOR: Eliseev Dmitry * */ public Message(final byte data[]) { m_Timestamp = System.currentTimeMillis(); m_Data = data; } /* End of 'Message::Message' method */ /* * * METHOD: Message class constructor * PARAM: [IN] data - bytes array data * AUTHOR: Eliseev Dmitry * */ public Message(final String data) { this(data.getBytes()); } /* End of 'Message::Message' method */ /* * * METHOD: Message class constructor * PARAM: [IN] object - some serializable object * AUTHOR: Eliseev Dmitry * */ public Message(final Object object) { this(CompressionUtility.compress(object)); } /* End of 'Message::Message' method */ /* * * METHOD: Bytes data representation getter * RETURN: Data bytes representation * AUTHOR: Eliseev Dmitry * */ public final byte[] getData() { return m_Data; } /* End of 'Message::getData' method */ /* * * METHOD: Gets message size * RETURN: Data size in bytes * AUTHOR: Eliseev Dmitry * */ public final int getSize() { return (m_Data != null)?m_Data.length:0; } /* End of 'Message::getSize' method */ @Override public final String toString() { return (m_Data != null)?new String(m_Data, Charset.forName("UTF-8")):null; } /* End of 'Message::toString' method */ /* * * METHOD: Compares two messages sizes * RETURN: TRUE if messages has same sizes, FALSE otherwise * PARAM: [IN] message - message to compare with this one * AUTHOR: Eliseev Dmitry * */ private boolean messagesHasSameSizes(final Message message) { return m_Data != null && m_Data.length == message.m_Data.length; } /* End of 'Message::messagesHasSameSize' method */ /* * * METHOD: Compares two messages by their values * RETURN: TRUE if messages has same sizes, FALSE otherwise * PARAM: [IN] message - message to compare with this one * AUTHOR: Eliseev Dmitry * */ private boolean messagesAreEqual(final Message message) { /* Messages has different sizes */ if (!messagesHasSameSizes(message)) return false; /* At least one of characters is not equal to same at another message */ for (int i = 0; i < message.m_Data.length; i++) if (m_Data[i] != message.m_Data[i]) return false; /* Messages are equal */ return true; } /* End of 'Message::messagesAreEqual' method */ /* * * METHOD: Tries to restore object, that may be packed in message * RETURN: Restored object if success, null otherwise * AUTHOR: Eliseev Dmitry * */ public final Object getObject() { return CompressionUtility.decompress(m_Data); } /* End of 'Message::getObject' method */ /* * * METHOD: Gets message sending time (in server time) * RETURN: Message sending time * AUTHOR: Eliseev Dmitry * */ public final long getTimestamp() { return m_Timestamp; } /* End of 'Message::getTimestamp' method */ @Override public final boolean equals(Object obj) { return obj instanceof Message && messagesAreEqual((Message) obj); } /* End of 'Message::equals' method */ @Override public final int hashCode() { return Arrays.hashCode(m_Data); } /* End of 'Message::hashCode' method */ } /* End of 'Message' class */

このオブジェクトの説明については詳しく説明しませんが、コードは非常にコメントされています。

ネットワークでの作業の簡素化は、次の2つのクラスの使用によるものです。

サーバー（サーバー側）
接続（クライアント側）

タイプServerのオブジェクトを作成する場合、着信接続を待機するポートとIServerHandlerインターフェースの実装を指定する必要があります

「IServerHandler.java」

 package com.gesoftware.venta.network.handlers; import com.gesoftware.venta.network.model.Message; import com.gesoftware.venta.network.model.ServerResponse; import java.net.InetAddress; /* Server handler interface declaration */ public interface IServerHandler { /* * * METHOD: Will be called right after new client connected * RETURN: True if you accept connected client, false if reject * PARAM: [IN] clientID - client identifier (store it somewhere) * PARAM: [IN] clientAddress - connected client information * AUTHOR: Eliseev Dmitry * */ public abstract boolean onConnect(final String clientID, final InetAddress clientAddress); /* * * METHOD: Will be called right after server accept message from any connected client * RETURN: Response (see ServerResponse class), or null if you want to disconnect client * PARAM: [IN] clientID - sender identifier * PARAM: [IN] message - received message * AUTHOR: Eliseev Dmitry * */ public abstract ServerResponse onReceive(final String clientID, final Message message); /* * * METHOD: Will be called right after any client disconnected * PARAM: [IN] clientID - disconnected client identifier * AUTHOR: Eliseev Dmitry * */ public abstract void onDisconnect(final String clientID); } /* End of 'IServerHandler' interface */

クライアントは、 Connectionタイプのオブジェクトを作成するときに、 IClientHandlerインターフェイスの実装を提供する必要があります。

「IClientHandler.java」

 package com.gesoftware.venta.network.handlers; import com.gesoftware.venta.network.model.Message; import com.gesoftware.venta.network.model.ServerResponse; import java.net.InetAddress; /* Server handler interface declaration */ public interface IServerHandler { /* * * METHOD: Will be called right after new client connected * RETURN: True if you accept connected client, false if reject * PARAM: [IN] clientID - client identifier (store it somewhere) * PARAM: [IN] clientAddress - connected client information * AUTHOR: Eliseev Dmitry * */ public abstract boolean onConnect(final String clientID, final InetAddress clientAddress); /* * * METHOD: Will be called right after server accept message from any connected client * RETURN: Response (see ServerResponse class), or null if you want to disconnect client * PARAM: [IN] clientID - sender identifier * PARAM: [IN] message - received message * AUTHOR: Eliseev Dmitry * */ public abstract ServerResponse onReceive(final String clientID, final Message message); /* * * METHOD: Will be called right after any client disconnected * PARAM: [IN] clientID - disconnected client identifier * AUTHOR: Eliseev Dmitry * */ public abstract void onDisconnect(final String clientID); } /* End of 'IServerHandler' interface */

サーバーの内部構造について少し説明します。次のクライアントがサーバーに参加するとすぐに、一意のハッシュが計算され、受信ストリームと送信ストリームの2つのストリームが作成されます。受信ストリームはブロックされ、クライアントからのメッセージを待ちます。クライアントからのメッセージが受信されるとすぐに、ライブラリユーザーが登録したハンドラーに送信されます。処理の結果、次の5つのイベントのいずれかが発生する場合があります。

クライアントの切断（切断要求が到着したとしましょう）
クライアントへの応答の送信
別のクライアントに応答を送信する
接続されているすべてのクライアントに応答を送信する
特定のクライアントグループに応答を送信する

接続されたクライアントの1つにメッセージを送信する必要がある場合、このクライアントのメッセージ送信キューに配置され、送信を担当するスレッドに新しいメッセージがキューに表示されたことが通知されます。

明らかに、データフローは次の図で示すことができます。

ライブラリのネットワークモジュールでのデータフロー

クライアントXはサーバーにリクエストを送信します（赤い矢印）。要求は、クライアントに対応するレシーバーストリームで受信されます。すぐにメッセージハンドラを呼び出します（黄色の矢印）。処理の結果、特定の応答が形成され、クライアントXの送信キューに配置されます（緑色の矢印）。送信ストリームは、送信キュー内のメッセージを確認し（黒い矢印）、クライアントに応答を送信します（青い矢印）。

例（マルチユーザーエコーサーバー）

 package com.gesoftware.venta.network; import com.gesoftware.venta.logging.LoggingUtility; import com.gesoftware.venta.network.handlers.IClientHandler; import com.gesoftware.venta.network.handlers.IServerHandler; import com.gesoftware.venta.network.model.Message; import com.gesoftware.venta.network.model.ServerResponse; import java.net.InetAddress; import java.util.TimerTask; public final class NetworkTest { private final static int c_Port = 5502; private static void startServer() { final Server server = new Server(c_Port, new IServerHandler() { @Override public boolean onConnect(final String clientID, final InetAddress clientAddress) { LoggingUtility.info("Client connected: " + clientID); return true; } @Override public ServerResponse onReceive(final String clientID, final Message message) { LoggingUtility.info("Client send message: " + message.toString()); return new ServerResponse(message); } @Override public void onDisconnect(final String clientID) { LoggingUtility.info("Client disconnected: " + clientID); } }); (new Thread(server)).start(); } private static class Task extends TimerTask { private final Connection m_Connection; public Task(final Connection connection) { m_Connection = connection; } @Override public void run() { m_Connection.send(new Message("Hello, current time is: " + System.currentTimeMillis())); } } private static void startClient() { final Connection connection = new Connection("localhost", c_Port, new IClientHandler() { @Override public void onReceive(final Message message) { LoggingUtility.info("Server answer: " + message.toString()); } @Override public void onConnectionLost(final String message) { LoggingUtility.info("Connection lost: " + message); } }); connection.connect(); (new java.util.Timer("Client")).schedule(new Task(connection), 0, 1000); } public static void main(final String args[]) { LoggingUtility.setLoggingLevel(LoggingUtility.LoggingLevel.LEVEL_DEBUG); startServer(); startClient(); } }

かなり短いですね。

ゲームサーバー

ゲームサーバーのアーキテクチャはマルチレベルです。すぐに私は彼女のスキームと、その後の説明をします。

サーバーアーキテクチャ図

そのため、データベースとの対話には接続プールが使用されます（私はBoneCPライブラリを使用しています）。プリペアドステートメントを使用するために、接続を自分のクラス（Ventaライブラリ）でラップしました。

DBConnection.java

 package com.gesoftware.venta.db; import com.gesoftware.venta.logging.LoggingUtility; import com.jolbox.bonecp.BoneCPConfig; import com.jolbox.bonecp.BoneCP; import java.io.InputStream; import java.util.AbstractList; import java.util.LinkedList; import java.util.HashMap; import java.util.Map; import java.sql.*; /** * DB connection class definition **/ public final class DBConnection { /* Connections pool */ private BoneCP m_Pool; /** * DB Statement class definition **/ public final class DBStatement { private final PreparedStatement m_Statement; private final Connection m_Connection; /* * * METHOD: Class constructor * PARAM: [IN] connection - current connection * PARAM: [IN] statement - statement, created from connection * AUTHOR: Dmitry Eliseev * */ private DBStatement(final Connection connection, final PreparedStatement statement) { m_Connection = connection; m_Statement = statement; } /* End of 'DBStatement::DBStatement' class */ /* * * METHOD: Integer parameter setter * RETURN: True if success, False otherwise * PARAM: [IN] index - parameter position * PARAM: [IN] value - parameter value * AUTHOR: Dmitry Eliseev * */ public final boolean setInteger(final int index, final int value) { try { m_Statement.setInt(index, value); return true; } catch (final SQLException e) { LoggingUtility.debug("Can't set integer value: " + value + " because of " + e.getMessage()); } return false; } /* End of 'DBStatement::setInteger' class */ /* * * METHOD: Long parameter setter * RETURN: True if success, False otherwise * PARAM: [IN] index - parameter position * PARAM: [IN] value - parameter value * AUTHOR: Dmitry Eliseev * */ public final boolean setLong(final int index, final long value) { try { m_Statement.setLong(index, value); return true; } catch (final SQLException e) { LoggingUtility.debug("Can't set long value: " + value + " because of " + e.getMessage()); } return false; } /* End of 'DBStatement::setLong' class */ /* * * METHOD: String parameter setter * RETURN: True if success, False otherwise * PARAM: [IN] index - parameter position * PARAM: [IN] value - parameter value * AUTHOR: Dmitry Eliseev * */ public final boolean setString(final int index, final String value) { try { m_Statement.setString(index, value); } catch (final SQLException e) { LoggingUtility.debug("Can't set string value: " + value + " because of " + e.getMessage()); } return false; } /* End of 'DBStatement::setString' class */ /* * * METHOD: Enum parameter setter * RETURN: True if success, False otherwise * PARAM: [IN] index - parameter position * PARAM: [IN] value - parameter value * AUTHOR: Dmitry Eliseev * */ public final boolean setEnum(final int index, final Enum value) { return setString(index, value.name()); } /* End of 'DBStatement::setEnum' method */ /* * * METHOD: Binary stream parameter setter * RETURN: True if success, False otherwise * PARAM: [IN] index - parameter position * PARAM: [IN] stream - stream * PARAM: [IN] long - data length * AUTHOR: Dmitry Eliseev * */ public final boolean setBinaryStream(final int index, final InputStream stream, final long length) { try { m_Statement.setBinaryStream(index, stream); return true; } catch (final SQLException e) { LoggingUtility.debug("Can't set stream value: " + stream + " because of " + e.getMessage()); } return false; } /* End of 'DBStatement::setBinaryStream' method */ } /* End of 'DBConnection::DBStatement' class */ /* * * METHOD: Class constructor * PARAM: [IN] host - Database service host * PARAM: [IN] port - Database service port * PARAM: [IN] name - Database name * PARAM: [IN] user - Database user's name * PARAM: [IN] pass - Database user's password * AUTHOR: Dmitry Eliseev * */ public DBConnection(final String host, final int port, final String name, final String user, final String pass) { final BoneCPConfig config = new BoneCPConfig(); config.setJdbcUrl("jdbc:mysql://" + host + ":" + port + "/" + name); config.setUsername(user); config.setPassword(pass); /* Pool size configuration */ config.setMaxConnectionsPerPartition(5); config.setMinConnectionsPerPartition(5); config.setPartitionCount(1); try { m_Pool = new BoneCP(config); } catch (final SQLException e) { LoggingUtility.error("Can't initialize connections pool: " + e.getMessage()); m_Pool = null; } } /* End of 'DBConnection::DBConnection' method */ @Override protected final void finalize() throws Throwable { super.finalize(); if (m_Pool != null) m_Pool.shutdown(); } /* End of 'DBConnection::finalize' method */ /* * * METHOD: Prepares statement using current connection * RETURN: Prepared statement * PARAM: [IN] query - SQL query * AUTHOR: Dmitry Eliseev * */ public final DBStatement createStatement(final String query) { try { LoggingUtility.debug("Total: " + m_Pool.getTotalCreatedConnections() + "; Free: " + m_Pool.getTotalFree() + "; Leased: " + m_Pool.getTotalLeased()); final Connection connection = m_Pool.getConnection(); return new DBStatement(connection, connection.prepareStatement(query, Statement.RETURN_GENERATED_KEYS)); } catch (final SQLException e) { LoggingUtility.error("Can't create prepared statement using query: " + e.getMessage()); } catch (final Exception e) { LoggingUtility.error("Connection wasn't established: " + e.getMessage()); } return null; } /* End of 'DBConnection::createStatement' method */ /* * * METHOD: Closes prepared statement * PARAM: [IN] sql - prepared statement * AUTHOR: Dmitry Eliseev * */ private void closeStatement(final DBStatement query) { if (query == null) return; try { if (query.m_Statement != null) query.m_Statement.close(); if (query.m_Connection != null) query.m_Connection.close(); } catch (final SQLException ignored) {} } /* End of 'DBConnection::closeStatement' method */ /* * * METHOD: Executes prepared statement like INSERT query * RETURN: Inserted item identifier if success, 0 otherwise * PARAM: [IN] sql - prepared statement * AUTHOR: Dmitry Eliseev * */ public final long insert(final DBStatement query) { try { /* Query execution */ query.m_Statement.execute(); /* Obtain last insert ID */ final ResultSet resultSet = query.m_Statement.getGeneratedKeys(); if (resultSet.next()) return resultSet.getInt(1); } catch (final SQLException e) { LoggingUtility.error("Can't execute insert query: " + query.toString()); } finally { closeStatement(query); } /* Insertion failed */ return 0; } /* End of 'DBConnection::insert' method */ /* * * METHOD: Executes prepared statement like UPDATE query * RETURN: True if success, False otherwise * PARAM: [IN] sql - prepared statement * AUTHOR: Dmitry Eliseev * */ public final boolean update(final DBStatement query) { try { query.m_Statement.execute(); return true; } catch (final SQLException e) { LoggingUtility.error("Can't execute update query: " + query.m_Statement.toString()); } finally { closeStatement(query); } /* Update failed */ return false; } /* End of 'DBConnection::update' method */ /* * * METHOD: Executes prepared statement like COUNT != 0 query * RETURN: True if exists, False otherwise * PARAM: [IN] sql - prepared statement * AUTHOR: Dmitry Eliseev * */ public final boolean exists(final DBStatement query) { final AbstractList<Map<String, Object>> results = select(query); return results != null && results.size() != 0; } /* End of 'DBConnection::DBConnection' method */ /* * * METHOD: Executes prepared statement like SELECT query * RETURN: List of records (maps) if success, null otherwise * PARAM: [IN] sql - prepared statement * AUTHOR: Dmitry Eliseev * */ public final AbstractList<Map<String, Object>> select(final DBStatement query) { try { /* Container for result set */ final AbstractList<Map<String, Object>> results = new LinkedList<Map<String, Object>>(); /* Query execution */ query.m_Statement.execute(); /* Determine columns meta data */ final ResultSetMetaData metaData = query.m_Statement.getMetaData(); /* Obtain real data */ final ResultSet resultSet = query.m_Statement.getResultSet(); while (resultSet.next()) { final Map<String, Object> row = new HashMap<String, Object>(); /* Copying fetched data */ for (int columnID = 1; columnID <= metaData.getColumnCount(); columnID++) row.put(metaData.getColumnName(columnID), resultSet.getObject(columnID)); /* Add row to results */ results.add(row); } /* That's it */ return results; } catch (final SQLException e) { LoggingUtility.error("Can't execute select query: " + query.toString()); } finally { closeStatement(query); } /* Return empty result */ return null; } /* End of 'DBConnection::select' method */ } /* End of 'DBConnection' class */

DBController.javaクラスにも注意を払う必要があります。

DBController.java

 package com.gesoftware.venta.db; import com.gesoftware.venta.logging.LoggingUtility; import java.util.*; /** * DB controller class definition **/ public abstract class DBController<T> { /* Real DB connection */ protected final DBConnection m_Connection; /* * * METHOD: Class constructor * PARAM: [IN] connection - real DB connection * AUTHOR: Dmitry Eliseev * */ protected DBController(final DBConnection connection) { m_Connection = connection; LoggingUtility.core(getClass().getCanonicalName() + " controller initialized"); } /* End of 'DBController::DBController' method */ /* * * METHOD: Requests collection of T objects using select statement * RETURN: Collection of objects if success, empty collection otherwise * PARAM: [IN] selectStatement - prepared select statement * AUTHOR: Dmitry Eliseev * */ protected final Collection<T> getCollection(final DBConnection.DBStatement selectStatement) { if (selectStatement == null) return new LinkedList<T>(); final AbstractList<Map<String, Object>> objectsCollection = m_Connection.select(selectStatement); if ((objectsCollection == null)||(objectsCollection.size() == 0)) return new LinkedList<T>(); final Collection<T> parsedObjectsCollection = new ArrayList<T>(objectsCollection.size()); for (final Map<String, Object> object : objectsCollection) parsedObjectsCollection.add(parse(object)); return parsedObjectsCollection; } /* End of 'DBController::getCollection' method */ /* * * METHOD: Requests one T object using select statement * RETURN: Object if success, null otherwise * PARAM: [IN] selectStatement - prepared select statement * AUTHOR: Dmitry Eliseev * */ protected final T getObject(final DBConnection.DBStatement selectStatement) { if (selectStatement == null) return null; final AbstractList<Map<String, Object>> objectsCollection = m_Connection.select(selectStatement); if ((objectsCollection == null)||(objectsCollection.size() != 1)) return null; return parse(objectsCollection.get(0)); } /* End of 'DBController::getObject' method */ /* * * METHOD: Parses object's map representation to real T object * RETURN: T object if success, null otherwise * PARAM: [IN] objectMap - object map, obtained by selection from DB * AUTHOR: Dmitry Eliseev * */ protected abstract T parse(final Map<String, Object> objectMap); } /* End of 'DBController' class */

DBControllerクラスは、特定のテーブルのオブジェクトを操作するように設計されています。サーバーアプリケーションでは、データベーステーブルごとにコントローラーが作成されます。コントローラレベルでは、データベースのデータを挿入、抽出、更新するためのメソッドが実装されます。

一部の操作では、複数のテーブルのデータを一度に変更する必要があります。このために、マネージャーレベルが作成されました。各マネージャーは、すべてのコントローラーにアクセスできます。マネージャーレベルでは、たとえば「ユーザーXを部屋Aに配置する」などの高レベルの操作が実装されます。新しいレベルの抽象化への移行に加えて、マネージャーはデータキャッシングメカニズムを実装します。たとえば、誰かが認証を試みたり、評価を知りたい場合は、データベースにアクセスする必要はありません。ユーザーまたはユーザー評価を担当するマネージャーがこのデータを保存します。したがって、データベースの全体的な負荷が軽減されます。

抽象化の次のレベルはハンドラーです。次のクラスは、IserverHandlerインターフェイスの実装として使用されます。

StickersHandler.java

 package com.gesoftware.stickers.server.handlers; import com.gesoftware.stickers.model.common.Definitions; public final class StickersHandler implements IServerHandler { private final Map<Class, StickersQueryHandler> m_Handlers = new SynchronizedMap<Class, StickersQueryHandler>(); private final StickersManager m_Context; private final JobsManager m_JobsManager; public StickersHandler(final DBConnection connection) { m_Context = new StickersManager(connection); m_JobsManager = new JobsManager(Definitions.c_TasksThreadSleepTime); registerQueriesHandlers(); registerJobs(); } private void registerJobs() { m_JobsManager.addTask(new TaskGameUpdateStatus(m_Context)); m_JobsManager.addTask(new TaskGameUpdatePhase(m_Context)); } private void registerQueriesHandlers() { /* Menu handlers */ m_Handlers.put(QueryAuthorization.class, new QueryAuthorizationHandler(m_Context)); m_Handlers.put(QueryRegistration.class, new QueryRegistrationHandler(m_Context)); m_Handlers.put(QueryRating.class, new QueryRatingHandler(m_Context)); /* Logout */ m_Handlers.put(QueryLogout.class, new QueryLogoutHandler(m_Context)); /* Rooms handlers */ m_Handlers.put(QueryRoomRefreshList.class, new QueryRoomRefreshListHandler(m_Context)); m_Handlers.put(QueryRoomCreate.class, new QueryRoomCreateHandler(m_Context)); m_Handlers.put(QueryRoomSelect.class, new QueryRoomSelectHandler(m_Context)); m_Handlers.put(QueryRoomLeave.class, new QueryRoomLeaveHandler(m_Context)); /* Games handler */ m_Handlers.put(QueryGameLeave.class, new QueryGameLeaveHandler(m_Context)); m_Handlers.put(QueryGameIsStarted.class, new QueryGameIsStartedHandler(m_Context)); m_Handlers.put(QueryGameWhichPhase.class, new QueryGameWhichPhaseHandler(m_Context)); /* Question handler */ m_Handlers.put(QueryGameAsk.class, new QueryGameAskHandler(m_Context)); /* Answer handler */ m_Handlers.put(QueryGameAnswer.class, new QueryGameAnswerHandler(m_Context)); /* Voting handler */ m_Handlers.put(QueryGameVote.class, new QueryGameVoteHandler(m_Context)); /* Users handler */ m_Handlers.put(QueryUserHasInvites.class, new QueryUserHasInvitesHandler(m_Context)); m_Handlers.put(QueryUserAvailable.class, new QueryUserAvailableHandler(m_Context)); m_Handlers.put(QueryUserInvite.class, new QueryUserInviteHandler(m_Context)); } @SuppressWarnings("unchecked") private synchronized Serializable userQuery(final String clientID, final Object query) { final StickersQueryHandler handler = getHandler(query.getClass()); if (handler == null) { LoggingUtility.error("Handler is not registered for " + query.getClass()); return new ResponseCommonMessage("Internal server error: can't process: " + query.getClass()); } return handler.processQuery(m_Context.getClientsManager().getClient(clientID), query); } private StickersQueryHandler getHandler(final Class c) { return m_Handlers.get(c); } private ServerResponse answer(final Serializable object) { return new ServerResponse(new Message(object)); } @Override public boolean onConnect(final String clientID, final InetAddress clientAddress) { LoggingUtility.info("User <" + clientID + "> connected from " + clientAddress.getHostAddress()); m_Context.getClientsManager().clientConnected(clientID); return true; } @Override public final ServerResponse onReceive(final String clientID, final Message message) { final Object object = message.getObject(); if (object == null) { LoggingUtility.error("Unknown object accepted"); return answer(new ResponseCommonMessage("Internal server error: empty object")); } return new ServerResponse(new Message(userQuery(clientID, object))); } @Override public void onDisconnect(final String clientID) { m_Context.getClientsManager().clientDisconnected(clientID); LoggingUtility.info("User <" + clientID + "> disconnected"); } public void stop() { m_JobsManager.stop(); } }

このクラスには、要求オブジェクトのクラスの対応するハンドラーオブジェクトへのマッピングが含まれます。私の意見では、このアプローチにより（実行時間は最速ではありませんが）コードを適切に編成できます。各ハンドラーは、リクエストに関連する特定のタスクを1つだけ解決します。たとえば、ユーザー登録。

ユーザー登録プロセッサー

 package com.gesoftware.stickers.server.handlers.registration; import com.gesoftware.stickers.model.enums.UserStatus; import com.gesoftware.stickers.model.objects.User; import com.gesoftware.stickers.model.queries.registration.QueryRegistration; import com.gesoftware.stickers.model.responses.registration.ResponseRegistrationInvalidEMail; import com.gesoftware.stickers.model.responses.registration.ResponseRegistrationFailed; import com.gesoftware.stickers.model.responses.registration.ResponseRegistrationSuccessfully; import com.gesoftware.stickers.model.responses.registration.ResponseUserAlreadyRegistered; import com.gesoftware.stickers.server.handlers.StickersQueryHandler; import com.gesoftware.stickers.server.managers.StickersManager; import com.gesoftware.venta.logging.LoggingUtility; import com.gesoftware.venta.utility.ValidationUtility; import java.io.Serializable; public final class QueryRegistrationHandler extends StickersQueryHandler<QueryRegistration> { public QueryRegistrationHandler(final StickersManager context) { super(context); } @Override public final Serializable process(final User user, final QueryRegistration query) { if (!ValidationUtility.isEMailValid(query.m_EMail)) return new ResponseRegistrationInvalidEMail(); if (m_Context.getUsersManager().isUserRegistered(query.m_EMail)) return new ResponseUserAlreadyRegistered(); if (!m_Context.getUsersManager().registerUser(query.m_EMail, query.m_PasswordHash, query.m_Name)) return new ResponseRegistrationFailed(); LoggingUtility.info("User <" + user.m_ClientID + "> registered as " + query.m_EMail); return new ResponseRegistrationSuccessfully(); } @Override public final UserStatus getStatus() { return UserStatus.NotLogged; } }

コードは非常に読みやすいですよね？

クライアントアプリケーション

クライアントアプリケーションは、ハンドラーとまったく同じロジックを実装しますが、サーバーの応答のみを実装します。 IClientHandlerインターフェイスから継承されたクラスに実装されます。

異なるアクティビティの数は、ゲームの状態の数と同じです。サーバーとの対話の原理は非常に簡単です。

ユーザーが何らかのアクションを実行します（たとえば、「ゲームを入力してください」ボタンをクリックします）
クライアントアプリケーションは、進行状況ダイアログをユーザーに表示します。
クライアントアプリケーションはユーザー資格情報をサーバーに送信します
サーバーはリクエストを処理し、レスポンスを送り返します
回答に対応するハンドラーは、進行状況ダイアログを非表示にします
応答が処理され、結果がクライアントに出力されます

したがって、クライアントとサーバーの両方のビジネスロジックは、多数の小さな構造化クラスに分割されます。

もう1つお話ししたいのは、アプリ内購入です。ここでいくつかの記事で見たように、アプリ内購入はアプリケーションを収益化するための非常に便利なソリューションです。私はアドバイスをすることにし、アプリケーションに広告を追加し、$ 1で無効にする機能を追加しました。

課金の処理を始めたばかりの頃、私はそれがGoogleでどのように機能するかを考えるのに膨大な時間を費やしました。 Googleが支払いに関する情報（支払い番号など）を発行し、ゲームサーバーに転送し、それから既にGoogle APIに連絡して確認を完了した後、論理的に思えるので、長い間サーバーで支払いを検証する方法を理解しようとしました支払いかどうか。結局のところ、そのようなスキームはサブスクリプションに対してのみ機能します。通常の購入では、すべてがはるかに簡単です。アプリケーションで購入を行うと、Googleは購入とそのステータス（チェック）およびこのチェックの電子署名に関する情報を含むJSONを返します。したがって、すべては「Googleを信頼していますか？」という質問にかかっています。 :)実際、そのようなペアを受信した後、ゲームサーバーに送信されます。ゲームサーバーは、次の2つのことを確認するだけで済みます。

既にそのようなリクエストをサーバーに送信しましたか（これは、ゲーム通貨の購入など、Googleによって制御されていない操作のためです）
小切手は電子署名で正しく署名されていますか（結局、共通のGoogleキーはサーバーを含むすべての人に知られています）

このメモでは、最初の混firstとした話を終わらせたいと思います。私は自分の記事を何度か読みましたが、これは技術的なテキストの理想ではなく、おそらく理解するのは難しいかもしれませんが、将来（もしそうなら）、状況を修正しようとします。

参照資料

サードパーティのライブラリ

おわりに

誰かが最後まで読む忍耐を持っていた場合、私はプロの作家のふりをしていないので、感謝を表します。ここで公開するのはこれが初めてなので、強く批判してください。この出版の理由の1つは、サーバーの負荷テストを行う必要があるだけでなく、ゲームの視聴者を募集する必要があると言われる「habraeffect」です。エラー/不正確さの兆候に感謝します。ご清聴ありがとうございました！

結論として、小さなアンケート（現時点では追加できません）：将来公開する価値はありますか？もしそうなら、どのトピックで出版物が興味を持ちますか：

数学：線形代数
数学：分析
数学：数値および最適化の方法
数学：離散数学とアルゴリズム理論
数学：計算幾何学
プログラミング：コンピューターグラフィックスの基礎（たとえば、このプロジェクト）
プログラミング：シェーダープログラミング
プログラミング：ゲーム開発
物理学：相対性理論
物理学：天体物理学

どこ？

Google Play用のゲームの作成方法について