Android學習筆記(七)之Android socket通信-解決中文亂碼

目前想讓手機用戶端和伺服器保持長連接配接故選擇socket進行通信

首先是建立一個socket伺服器端

[java] 

view

plain

copy

1. /** 
2.  * Main.java 
3.  * 版權所有(C) 2012  
4.  * 建立:cuiran 2012-09-14 08:56:16 
5.  */  
6. package com.wpndemo.socket;  
7. import java.io.BufferedReader;    
8. import java.io.BufferedWriter;    
9. import java.io.IOException;    
10. import java.io.InputStreamReader;    
11. import java.io.OutputStreamWriter;    
12. import java.io.PrintWriter;    
13. import java.net.ServerSocket;    
14. import java.net.Socket;    
15. import java.util.ArrayList;    
16. import java.util.List;    
17. import java.util.concurrent.ExecutorService;    
18. import java.util.concurrent.Executors;    
20.  * TODO 
21.  * @author cuiran 
22.  * @version TODO 
24. public class Main {  
25.     private static final int PORT = 8090;    
26.     private List<Socket> mList = new ArrayList<Socket>();    
27.     private ServerSocket server = null;    
28.     private ExecutorService mExecutorService = null; //thread pool     
29.     public static final String bm="utf-8"; //全局定義，以适應系統其他部分  
30.     public static void main(String[] args) {    
31.         new Main();    
32.     }    
33.     public Main() {    
34.         try {    
35.             server = new ServerSocket(PORT);    
36.             mExecutorService = Executors.newCachedThreadPool();  //create a thread pool     
37.             System.out.print("server start ...");    
38.             Socket client = null;    
39.             while(true) {    
40.                 client = server.accept();    
41.                 mList.add(client);    
42.                 mExecutorService.execute(new Service(client)); //start a new thread to handle the connection     
43.             }    
44.         }catch (Exception e) {    
45.             e.printStackTrace();    
46.         }    
48.     class Service implements Runnable {    
49.             private Socket socket;    
50.             private BufferedReader in = null;    
51.             private String msg = "";    
52.             public Service(Socket socket) {    
53.                 this.socket = socket;    
54.                 try {    
55.                     in = new BufferedReader(new InputStreamReader(socket.getInputStream(),bm));    
56.                     msg = "user" +this.socket.getInetAddress() + "come toal:"    
57.                         +mList.size();    
58.                     this.sendmsg();    
59.                 } catch (IOException e) {    
60.                     e.printStackTrace();    
61.                 }    
63.             @Override    
64.             public void run() {    
65.                 // TODO Auto-generated method stub     
67.                     while(true) {    
68.                         if((msg = in.readLine())!= null) {    
69.                             if(msg.equals("exit")) {    
70.                                 System.out.println("ssssssss");    
71.                                 mList.remove(socket);    
72.                                 in.close();    
73.                                 msg = "user:" + socket.getInetAddress()    
74.                                     + "exit total:" + mList.size();    
75.                                 socket.close();    
76.                                 this.sendmsg();    
77.                                 break;    
78.                             } else {    
79.                                 System.out.println("msg="+msg);  
80.                                 msg = socket.getInetAddress() + ":" + msg;    
82.                             }    
83.                         }    
84.                     }    
85.                 } catch (Exception e) {    
89.            public void sendmsg() {    
90.                System.out.println(msg);    
91.                int num =mList.size();    
92.                for (int index = 0; index < num; index ++) {    
93.                    Socket mSocket = mList.get(index);    
94.                    PrintWriter pout = null;    
95.                    try {    
96.                        pout = new PrintWriter(new BufferedWriter(    
97.                                new OutputStreamWriter(mSocket.getOutputStream(),bm)),true);    
98.                        pout.println(msg);    
99.                    }catch (IOException e) {    
100.                        e.printStackTrace();    
101.                    }    
102.                }    
103.            }    
104.         }   
105. }  

然後是建立一個android工程：

在檔案【AndroidManifest.xml】添加内容：

[html] 

1. <?xml version="1.0" encoding="utf-8"?>  
2. <manifest xmlns:android="http://schemas.android.com/apk/res/android"  
3.     package="com.cayden.socket"  
4.     android:versionCode="1"  
5.     android:versionName="1.0" >  
6.     <uses-sdk android:minSdkVersion="8" />  
7.     <uses-permission android:name="android.permission.INTERNET" />  
8.     <uses-permission android:name="android.permission.ACCESS_COARSE_LOCATION" />  
9.     <uses-permission android:name="android.permission.READ_PHONE_STATE"></uses-permission>  
10.     <application  
11.         android:icon="@drawable/ic_launcher"  
12.         android:label="@string/app_name" >  
13.         <activity  
14.             android:name=".SocketActivity"  
15.             android:label="@string/app_name" >  
16.             <intent-filter>  
17.                 <action android:name="android.intent.action.MAIN" />  
18.                 <category android:name="android.intent.category.LAUNCHER" />  
19.             </intent-filter>  
20.         </activity>  
21.     </application>  
22. </manifest>  

然後是建立類：

1. package com.cayden.socket;  
2. import java.io.BufferedReader;  
3. import java.io.BufferedWriter;  
4. import java.io.IOException;  
5. import java.io.InputStreamReader;  
6. import java.io.OutputStreamWriter;  
7. import java.io.PrintWriter;  
8. import java.io.UnsupportedEncodingException;  
9. import java.net.Socket;  
10. import com.cayden.util.Conf;  
11. import android.app.Activity;  
12. import android.app.AlertDialog;  
13. import android.content.DialogInterface;  
14. import android.os.Bundle;  
15. import android.os.Handler;  
16. import android.os.Message;  
17. import android.util.Log;  
18. import android.view.View;  
19. import android.widget.Button;  
20. import android.widget.EditText;  
21. import android.widget.TextView;  
22. public class SocketActivity extends Activity implements Runnable {  
23.     private TextView tv_msg = null;    
24.     private EditText ed_msg = null;    
25.     private Button btn_send = null;    
26. //    private Button btn_login = null;     
27.     private static final String HOST = "219.143.49.189";    
28.     private static final int PORT = 8403;    
29.     private Socket socket = null;    
30.     private BufferedReader in = null;    
31.     private PrintWriter out = null;    
32.     private String content = "";    
34.     /** Called when the activity is first created. */  
35.     @Override  
36.     public void onCreate(Bundle savedInstanceState) {  
37.         super.onCreate(savedInstanceState);  
38.         setContentView(R.layout.main);  
39.         tv_msg = (TextView) findViewById(R.id.TextView);    
40.         ed_msg = (EditText) findViewById(R.id.EditText01);    
41. //        btn_login = (Button) findViewById(R.id.Button01);     
42.         btn_send = (Button) findViewById(R.id.sendBtn);    
44.             socket = new Socket(HOST, PORT);    
45.             in = new BufferedReader(new InputStreamReader(socket.getInputStream()));    
46.             out = new PrintWriter(new BufferedWriter(new OutputStreamWriter(    
47.                     socket.getOutputStream(),bm)), true);  
48.             Log.i(Conf.TAG, "連接配接成功");  
49.         } catch (IOException ex) {    
50.             ex.printStackTrace();   
51.             Log.i(Conf.TAG, "出現異常："+ex.getMessage());  
52.             ShowDialog("login exception" + ex.getMessage());    
54.         btn_send.setOnClickListener(new Button.OnClickListener() {    
56.             public void onClick(View v) {    
58.                 String msg = ed_msg.getText().toString();    
59.                 if (socket.isConnected()) {    
60.                     if (!socket.isOutputShutdown()) {    
61.                         try {  
62.                             out.println(msg);  
63.                         } catch (Exception e) {  
64.                             e.printStackTrace();  
69.         });    
70.         new Thread(SocketActivity.this).start();    
71.     }  
72.     public void ShowDialog(String msg) {    
73.         new AlertDialog.Builder(this).setTitle("notification").setMessage(msg)    
74.                 .setPositiveButton("ok", new DialogInterface.OnClickListener() {    
75.                     @Override    
76.                     public void onClick(DialogInterface dialog, int which) {    
78.                 }).show();    
81.     public void run() {  
82.         // TODO Auto-generated method stub  
84.             while (true) {    
86.                     if (!socket.isInputShutdown()) {    
87.                         if ((content = in.readLine()) != null) {    
88.                             content += "\n";    
89.                             mHandler.sendMessage(mHandler.obtainMessage());    
90.                         } else {    
95.         } catch (Exception e) {    
99.      public Handler mHandler = new Handler() {    
100.             public void handleMessage(Message msg) {    
101.                 super.handleMessage(msg);    
102.                 tv_msg.setText(tv_msg.getText().toString() + content);    
104.         };    
105. }