socket close!! 什么原因导致的呢

Question

08-09 22:01:27.945: E/mango(9898): +++start discovering+++
08-09 22:01:54.445: D/ActivityThread(9898): test selfappwidget  getPackageInfo,packageInfo 000=android.app.LoadedApk@40515458
08-09 22:01:54.476: E/mango(9898): +++start discovering+++
08-09 22:01:58.257: I/System.out(9898): 新发现的设备：mango
08-09 22:01:58.273: E/mango(9898): +++与设备配对+++
08-09 22:01:58.273: E/mango(9898): 获取远程设备
08-09 22:01:58.289: I/System.out(9898): 客户端的socket连接开始
08-09 22:02:05.750: I/System.out(9898): socket1android.bluetooth.BluetoothSocket@4055b5a0
08-09 22:02:05.750: I/System.out(9898): socket2android.bluetooth.BluetoothSocket@4055b5a0
08-09 22:02:05.757: I/System.out(9898): 进入管理线程的函数：connected
08-09 22:02:05.812: I/System.out(9898): 进入clientthread,开始write数据流
08-09 22:02:05.812: I/System.out(9898): send:[B@405604f8
08-09 22:02:05.820: W/System.err(9898): java.io.IOException: socket closed
08-09 22:02:05.820: W/System.err(9898):  at android.bluetooth.BluetoothSocket.write(BluetoothSocket.java:316)
08-09 22:02:05.820: W/System.err(9898):  at android.bluetooth.BluetoothOutputStream.write(BluetoothOutputStream.java:85)
08-09 22:02:05.820: W/System.err(9898):  at java.io.OutputStream.write(OutputStream.java:80)
08-09 22:02:05.820: W/System.err(9898):  at com.card.mango.sendcard$ClientThread.<init>(sendcard.java:223)
08-09 22:02:05.820: W/System.err(9898):  at com.card.mango.sendcard.connected(sendcard.java:202)
08-09 22:02:05.820: W/System.err(9898):  at com.card.mango.sendcard$ConnectThread.run(sendcard.java:169)
代码如下//客户端   需要开启蓝牙 搜索设备  建立socket write数据package com.card.mango;import java.io.IOException;
import java.io.OutputStream;
import java.util.UUID;
import android.app.Activity;
import android.bluetooth.BluetoothAdapter;
import android.bluetooth.BluetoothDevice;
import android.bluetooth.BluetoothSocket;
import android.content.BroadcastReceiver;
import android.content.Context;
import android.content.Intent;
import android.content.IntentFilter;
import android.os.Bundle;
import android.util.Log;
import android.widget.ImageView;
import android.widget.TextView;
import android.widget.Toast;public class sendcard extends Activity {    // Local Bluetooth adapter
    private BluetoothAdapter mBluetoothAdapter = null;
    private ConnectThread mConnectThread;
    private ClientThread mClientThread;   
    private static final String Name = "mango"; 
    String defaultname = "abc";
    
User user;   //得到user实例和需要交换的数据
String exchange_name="0";
int exchange_image=0;
private TextView et_name;
private ImageView imageView;    
    @Override 
    public void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.exchange);
        
        // Get local Bluetooth adapter
        mBluetoothAdapter = BluetoothAdapter.getDefaultAdapter();
 
     // If the adapter is null, then Bluetooth is not supported
        if (mBluetoothAdapter == null) {
            Toast.makeText(this, "蓝牙不可用", Toast.LENGTH_LONG).show();
            finish();
            return;
        }        
        if (!mBluetoothAdapter.isEnabled()) {
            //直接打开蓝牙设备
         mBluetoothAdapter.enable();
         }
        
        // Register for broadcasts when a device is discovered
        IntentFilter filter = new IntentFilter(BluetoothDevice.ACTION_FOUND);
        this.registerReceiver(mReceiver, filter);
    }    @Override
    public void onStart() {
        super.onStart();
        //搜索周围的蓝牙设备
        if (mBluetoothAdapter.isDiscovering()) {
         mBluetoothAdapter.cancelDiscovery();
        }
        mBluetoothAdapter.startDiscovery();
        if(true){Log.e(Name, "+++start discovering+++");}//test    }
        //自定义广播类
    
    private final BroadcastReceiver mReceiver = new BroadcastReceiver() {
            @Override
            public void onReceive(Context context, Intent intent) {
                String action = intent.getAction(); 
                
                // When discovery finds a device
                
                if (BluetoothDevice.ACTION_FOUND.equals(action)) {
                
                    // Get the BluetoothDevice object from the Intent
                    BluetoothDevice device = intent.getParcelableExtra(BluetoothDevice.EXTRA_DEVICE);
                    System.out.println("新发现的设备："+device.getName());  
                    
                   // 如果查找到的设备符合要连接的设备，处理    
                  if (device.getName().equalsIgnoreCase(Name)) {   
                   
                    // 搜索蓝牙设备的过程占用资源比较多，一旦找到需要连接的设备后需要及时关闭搜索    
                 mBluetoothAdapter.cancelDiscovery();                    //与搜索到的设备连接
                      if(true){Log.e(Name, "+++与设备配对+++");}//test
                      try {
                          //调用connect函数与设备连接
                           connect(device);
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}           
                   }else{ System.out.println("未找到想要的设备");
                 }
                }
            }
      };    //与蓝牙设备连接
    
    private void connect(BluetoothDevice device) throws IOException { 
    
     // Get the BLuetoothDevice object
     String macadress=device.getAddress();   
     if (BluetoothAdapter.checkBluetoothAddress(macadress)){
        BluetoothDevice mdevice = mBluetoothAdapter.getRemoteDevice(macadress);
        
        if(true){Log.e(Name, "获取远程设备");}//test
        
     // Start the thread to connect with the given device
        
        mConnectThread = new ConnectThread(mdevice);
        mConnectThread.start();
     }    
    };
  
    private  class ConnectThread extends Thread {
           private final BluetoothSocket msocket;
           private final BluetoothDevice mdevice;
           final String SPP_UUID = "00001101-0000-1000-8000-00805F9B34FB";   
           UUID uuid = UUID.fromString(SPP_UUID); 
 
        public ConnectThread(BluetoothDevice device) {
        
         //建立socket连接
               BluetoothSocket tmp = null;
               mdevice = device;
            try {
                 tmp = mdevice.createRfcommSocketToServiceRecord(uuid);
            } catch (IOException e) { e.printStackTrace(); }
               msocket = tmp;
            }
 
        public void run() {
            // Cancel discovery because it will slow down the connection
            mBluetoothAdapter.cancelDiscovery();
 
          try {
            // Connect the device through the socket. This will block
            // until it succeeds or throws an exception
         System.out.println("客户端的socket连接开始"); 
         msocket.connect();
         System.out.println("socket1"+msocket); 
        
           } catch (IOException e) {e.printStackTrace();
            // Unable to connect; close the socket and get out
          //  try {
          //   msocket.close();
          //   System.out.println("客户端的socket连接失败，无法连接到对方");
          //  } catch (IOException closeException) {}
         //   return;
          }
            
           // Do work to manage the connection (in a separate thread)
            try {
             System.out.println("socket2"+msocket); 
connected(msocket);
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
        }       /** Will cancel an in-progress connection, and close the socket */
        public void cancel() {
             try {
                  msocket.close();
            } catch (IOException e) { }
       }
}public synchronized void connected(BluetoothSocket socket) throws IOException {    // Cancel the thread that completed the connection
    if (mConnectThread != null) {mConnectThread.cancel(); mConnectThread = null;}    System.out.println("进入管理线程的函数：connected"); 
    
    //获得意图  
Intent intent = getIntent();
//从意图中得到需要的user对象 并保存即将用蓝牙传输的数据
user = (User) intent.getSerializableExtra("user");
et_name = (TextView) findViewById(R.id.username);
imageView = (ImageView)findViewById(R.id.imageId);
exchange_name=user.username;
exchange_image=user.imageId;
        
    // Start the thread to manage the connection and perform transmissions
if(socket!=null){
    mClientThread = new ClientThread(socket, exchange_name, exchange_image);
    mClientThread.start();
}
    
}private class ClientThread extends Thread {
  private final BluetoothSocket mmSocket;
      private final OutputStream mmOutStream;
    
    public ClientThread(BluetoothSocket socket , String exchange_name , int exchange_image) throws IOException{        System.out.println("进入clientthread,开始write数据流");
        
          mmSocket = socket;
          mmOutStream = mmSocket.getOutputStream();
  
        // 向socket对象所获取的流中发送数据
          try {
           byte[] send = exchange_name.getBytes();
           System.out.println("send:"+send);
           mmOutStream.write(send);
           mmOutStream.flush();
          } catch (IOException e) {e.printStackTrace(); }
          finally{
           cancel();
          }
          
    }
 
    /* Call this from the main activity to shutdown the connection */
    public void cancel() {
        try {
        
         mmSocket.close();
        } catch (IOException e) { }
    }
}@Override
protected void onDestroy() {
    super.onDestroy();
    // Unregister broadcast listeners
    this.unregisterReceiver(mReceiver);
}
public synchronized void stop() {    if (mConnectThread != null) {
        mConnectThread.cancel();
        mConnectThread = null;
    }    if (mClientThread != null) {
     mClientThread.cancel();
     mClientThread = null;
    }}
}

Answer 1

try {
  byte[] send = exchange_name.getBytes();
  System.out.println("send:"+send);
  mmOutStream.write(send);
  mmOutStream.flush();
  } catch (IOException e) {e.printStackTrace(); }
  finally{
  cancel();////////////////////流出错，到finally，执行cancel方法关闭了socket
  }
    
  }