コードのデバッグが少し難しくなり始めているため、設計の選択が理想的ではないと思い込んでいます。私は初心者の Android プログラミングであり、最適な操作のために設計を合理化するための助けが欲しい.
はじめに
rfcomm インターフェイスを使用してクライアント デバイスとサーバー デバイスの間でデータを転送するアプリケーションを作成しています。クライアントは、特定のキーを使用してサーバーから特定のものを要求する必要があり、サーバーが結果を返すまで待機する必要があります。
現在の設計
- ボタンを押すと、サーバーからの情報の要求がトリガーされます。
- リクエストを実行する新しいスレッドが開始されます。
- 一意の整数であるキーがバイト配列に変換され、サーバーに送信されます。
- スレッドには、サーバーからの応答を示す特定のブール値が false から true に切り替わるのを待機している while ループがあります。
- サーバー側で情報を受け取ります。サーバーはキーを使用して、次に何をすべきかを識別します。
- サーバーはスレッドを開始してクエリを実行し、結果として jsonString を取得します。
- サーバーは、バイト配列に変換された jsonstring を、先頭に同じ識別キーを付けてクライアントに送り返します。
- クライアントはメッセージを読み取り、識別キーに基づいてバイト配列を処理メソッドに送信します。
- 処理メソッドは jsonString をクラス変数に格納し、ブール値を反転して、待機していた値が設定されたことを他のスレッドに知らせます。
- Json 文字列はクライアント側でオブジェクトに変換されます。そのオブジェクトで何かが行われます。
このコードは現在、情報をサーバーに正しく送信し、サーバーは正しく検索を行い、有効な json 文字列の結果を取得します。ただし、サーバーがその結果をクライアントに書き込むときに問題が発生します。1 件ではなく 20 件のメッセージが表示され、検索キーに一致するメッセージはありません...
私の質問
- デザインに関して効率的な方法で物事を行っていますか?
synchronizedコードをよりスレッド セーフにするために、キーワード or and and Atomic Boolean を使用するメリットはありますか? どうすれば実装できますか？- 文字列をバイト配列に変換するための最大長はありますか? コードが送信を分割しようとしているのかもしれません。そのため、20 の異なる結果が得られます。
関連コード
public class ClientSpokesmanClass {
private final int searchKey = 2222222; //set the key to some int.
private boolean pendingSearchResults = false;
List<Place> places = new ArrayList<Place>();
private final Handler handler = new Handler(){
@Override
public void handleMessage(Message msg){
switch(msg.what) {
...
case MESSAGE_READ:
//Message received from server
readAndDistribute(msg.arg1, msg.obj);
break;
...
}
}
};
public List<Place> getPlacesFromServer(String query){
//ask server for search results
requestSearchFromServer(query);
//just wait for them...
while (pendingSearchResults){
//just waiting
}
return places;
}
private void requestSearchFromConnectedDevice(String query) {
if (mBluetoothState == STATE_CONNECTED){
byte[] bites = new byte[4];
bites = ByteBuffer.wrap(bites).putInt(searchKey).array();
byte[] stringBytes = null;
try {
stringBytes = query.getBytes("UTF-8");
} catch (UnsupportedEncodingException e) {
// TODO Auto-generated catch block
Log.e(TAG, "unsupported encoding", e);
}
int keyLength = bites.length;
int stringLength = stringBytes.length;
byte[] combined = new byte[keyLength+stringLength];
System.arraycopy(bites, 0, combined, 0, keyLength);
System.arraycopy(stringBytes, 0, combined, keyLength, stringLength);
mBluetoothService.write(combined);
}
pendingSearchResults = true;
}
private void receiveSearchResults(byte[] bites){
String jsonString = "";
PlacesJSONParser parser = new PlacesJSONParser();
try {
jsonString = new String(bites, "UTF-8");
} catch (UnsupportedEncodingException e) {
// TODO Auto-generated catch block
Log.e(TAG, "unsupported encoding", e);
}
if (D) Log.d(TAG, "Json string we got is "+jsonString);
try {
places = parser.parse(new JSONObject(jsonString));
} catch (JSONException e) {
// TODO Auto-generated catch block
Log.e(TAG, "JSON exception", e);
}
pendingSearchResults = false;
}
/**
* Reads come here first. Then, based on the key prepended to them,
* they then go to other methods for further work.
* @param bytes
* @param buffer
*/
private synchronized void readAndDistribute(int bytes, Object buffer){
byte[] buff = (byte[]) buffer;
int key = ByteBuffer.wrap(Arrays.copyOfRange(buff, 0, 4)).getInt();
if (key == searchKey){
receiveSearchResults(Arrays.copyOfRange(buff, 4, bytes));
}else{
//do something else
}
}
}
.
public class ClientUI extends Activity {
...
onQueryTextSubmit(String query){
final String queryFinal = query;
Thread thread = new Thread(){
public void run() {
places = ClientSpokesmanClass.getPlacesFromServer(query);
doSomethingWithPlaces();
}
};
thread.start();
}
}
.
public class ServerReceive {
private searchKey = 2222222;
...
//code that handles messages, reads key, and then runs doSearchAndWriteResults()
...
private synchronized void doSearchAndWriteResults(byte[] bites){
if (D) Log.d(TAG, "+++writeSearchResults");
//Initialize query and placesString
String query = null;
String placesString;
//Convert byte array to the query string
try {
query = new String(bites, "UTF-8");
} catch (UnsupportedEncodingException e) {
// TODO Auto-generated catch block
Log.e(TAG, "unsupported encoding",e);
}
//if the string was converted successfully...
if (query != null){
//Run the places query and set the json string to placesString
if (D) Log.d(TAG, "query is "+query);
PlacesProvider placeProvider = new PlacesProvider();
placesString = placeProvider.getPlacesString(query);
}
//initialize a bite array
byte[] stringBytes = null;
try {
//convert jsonString to byte array
stringBytes = placesString.getBytes("UTF-8");
} catch (UnsupportedEncodingException e) {
// TODO Auto-generated catch block
Log.e(TAG, "unsupported encoding",e);
}
//Put the search key to a byte array. I am using this key on the client side
//to confirm that we are reading searchResults and not some other type of write.
byte[] bite = new byte[4];
bite = ByteBuffer.wrap(bite).putInt(searchKey).array();
//Get the lengths of the two byte arrays
int keyLength = bite.length;
int stringLength = stringBytes.length;
//combine the byte arrays for sending
byte[] combined = new byte[keyLength+stringLength];
System.arraycopy(bite, 0, combined, 0, keyLength);
System.arraycopy(stringBytes, 0, combined, keyLength, stringLength);
if (D) Log.d(TAG, "Actually writing things here...");
//send the byte arrrays over rfcomm
mBluetoothService.write(combined);
}
}