当我需要将字符串从服务器蓝牙套接字发送到客户端蓝牙套接字时,我的程序遇到了麻烦。
只要我一次只发送一个字符串(例如聊天),一切都可以正常工作,但是如果我需要在短时间内编写更多字符串(以交换信息),则字符串将不会与客户端代码分离。例如,如果我发送“FirstUser”,然后发送“SecondUser”,则客户端不会先读取“FirstUser”,然后再读取“SecondUser”。它将显示为“FirstUserSecondUser”。我怎样才能避免这种行为?
编辑:如果我让线程在发送新消息之前休眠,它会读取正确的字符串,但此解决方案无法正常满足我的需要。
服务器代码:发送给所有客户端(已编辑)
public synchronized void sendToAll(String message)
{
try {
Thread.sleep(100);
} catch (InterruptedException e1) {
e1.printStackTrace();
}
publishProgress(message);
for(OutputStream writer:outputList) {
try {
writer.write(message.getBytes());
writer.flush();
} catch (IOException e) {
System.out.println("Some-Error-Code");
}
}
}
服务器代码:从客户端读取:
public void run() {
String nachricht;
int numRead;
byte[] buffer = new byte[1024];
while (runningFlag)
{
try {
if((numRead = inputStream.read(buffer)) >= 0) {
nachricht = new String(buffer, 0, numRead);
serverThread.handleMessage(nachricht);
}
}
catch (IOException e) {
this.cancel();
e.printStackTrace();
}
}
}
客户端代码:从服务器读取(已编辑)
@Override
protected Void doInBackground(Integer... ints) {
String nachricht = new String();
byte[] buffer = new byte[1024];
int numRead;
while (runningFlag)
{
try {
if(((numRead = inputStream.read(buffer)) >= 0)) {
nachricht = new String(buffer, 0, numRead);
publishProgress(nachricht);
}
}
catch (IOException e) {
clientGame.finish();
e.printStackTrace();
}
}
return null;
}
客户端代码:写入服务器
public synchronized void write(String nachricht)
{
try {
Thread.sleep(100);
} catch (InterruptedException e1) {
e1.printStackTrace();
}
try {
outputStream.write(nachricht.getBytes());
outputStream.flush();
} catch (IOException e) {
this.cancel();
e.printStackTrace();
}
}
我很感激每一个小小的帮助:)。