Socket网络通信例子

  1 package com.Aina.Android;  
  2 import java.io.BufferedReader;   
  3 import java.io.BufferedWriter;   
  4 import java.io.InputStreamReader;   
  5 import java.io.OutputStreamWriter;   
  6 import java.io.PrintWriter;   
  7 import java.net.Socket;   
  8   
  9 import android.app.Activity;   
 10 import android.app.AlertDialog;   
 11 import android.content.DialogInterface;   
 12 import android.os.Bundle;   
 13 import android.os.Handler;   
 14 import android.os.Message;   
 15 import android.util.Log;   
 16 import android.view.View;   
 17 import android.widget.Button;   
 18 import android.widget.EditText;   
 19 import android.widget.TextView;   
 20   
 21 public class Test extends Activity implements Runnable {   
 22     /** Called when the activity is first created. */  
 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 = "192.168.0.132";   
 28     private static final int PORT = 9999;   
 29     private Socket socket = null;   
 30     private BufferedReader in = null;   
 31     private PrintWriter out = null;   
 32     private String content = "";   
 33   
 34     @Override  
 35     public void onCreate(Bundle savedInstanceState) {   
 36         super.onCreate(savedInstanceState);   
 37         setContentView(R.layout.main);   
 38         tv_msg = (TextView) this.findViewById(R.id.TextView);   
 39         ed_msg = (EditText) this.findViewById(R.id.EditText01);   
 40         btn_login = (Button) this.findViewById(R.id.Button01);   
 41         btn_send = (Button) this.findViewById(R.id.Button02);   
 42         try {   
 43             socket = new Socket(HOST, PORT);   
 44             in = new BufferedReader(new InputStreamReader(socket   
 45                     .getInputStream()));   
 46             out = new PrintWriter(new BufferedWriter(   
 47                     new OutputStreamWriter(socket.getOutputStream())),   
 48                     true);   
 49         } catch (Exception ex) {   
 50             ex.printStackTrace();   
 51             ShowDialog("登陆异常:" + ex.getMessage());   
 52         }   
 53         btn_send.setOnClickListener(new Button.OnClickListener() {   
 54   
 55             public void onClick(View v) {   
 56                 // TODO Auto-generated method stub  
 57                 String msg = ed_msg.getText().toString();   
 58                 if (socket.isConnected()) {   
 59                     if (!socket.isOutputShutdown()) {   
 60                         out.println(msg);   
 61                     }   
 62                 }   
 63             }   
 64   
 65         });   
 66         new Thread(this).start();   
 67     }   
 68   
 69     public void ShowDialog(String msg) {   
 70         new AlertDialog.Builder(this).setTitle("提示").setMessage(msg)   
 71                 .setPositiveButton("OK", new DialogInterface.OnClickListener() {   
 72   
 73                     public void onClick(DialogInterface dialog, int which) {   
 74                         // TODO Auto-generated method stub  
 75   
 76                     }   
 77   
 78                 }).show();   
 79     }   
 80   
 81     public void run() {   
 82         try {   
 83             while (true) {   
 84                 if(socket.isConnected()){   
 85                     if(!socket.isInputShutdown()){   
 86                         if ((content = in.readLine()) != null) {   
 87                             Log.i("TAG", "++ "+content);   
 88                             content += "\n";   
 89                             mHandler.sendMessage(mHandler.obtainMessage());   
 90                         }else{   
 91                                
 92                         }   
 93                     }   
 94                 }   
 95                    
 96             }   
 97         } catch (Exception ex) {   
 98             ex.printStackTrace();   
 99         }   
100     }   
101   
102     public Handler mHandler = new Handler() {   
103         public void handleMessage(Message msg) {   
104             super.handleMessage(msg);   
105             Log.i("TAG", "-- "+msg);   
106             tv_msg.setText(tv_msg.getText().toString() + content);   
107         }   
108     };   
109 }

服务端程序：

  1 package com;   
  2   
  3 import java.io.BufferedReader;   
  4 import java.io.BufferedWriter;   
  5 import java.io.IOException;   
  6 import java.io.InputStreamReader;   
  7 import java.io.OutputStreamWriter;   
  8 import java.io.PrintWriter;   
  9 import java.net.ServerSocket;   
 10 import java.net.Socket;   
 11 import java.util.ArrayList;   
 12 import java.util.List;   
 13 import java.util.concurrent.ExecutorService;   
 14 import java.util.concurrent.Executors;   
 15   
 16 /**  
 17  * com Server  
 18  *   
 19  * @author Aina.huang E-mail: 674023920@qq.com  
 20  * @version 创建时间：2010 Jul 14, 2010 10:45:35 AM 类说明 
 21  */  
 22 public class Main {   
 23   
 24     private static final int PORT = 9999;// 端口监听  
 25     private List<Socket> mList = new ArrayList<Socket>();// 存放客户端socket  
 26     private ServerSocket server = null;   
 27     private ExecutorService mExecutorService = null;// 线程池  
 28   
 29     /**  
 30      * @param args  
 31      */  
 32     public static void main(String[] args) {   
 33         // TODO Auto-generated method stub  
 34         new Main();   
 35     }   
 36   
 37     public Main() {   
 38         try {   
 39             server = new ServerSocket(PORT);   
 40             mExecutorService = Executors.newCachedThreadPool();// 创建一个线程池  
 41             System.out.println("Server Start...");   
 42             Socket client = null;   
 43             while (true) {   
 44                 client = server.accept();   
 45                 mList.add(client);   
 46                 mExecutorService.execute(new Service(client));// 开启一个客户端线程.  
 47             }   
 48         } catch (Exception ex) {   
 49             ex.printStackTrace();   
 50         }   
 51     }   
 52   
 53     public class Service implements Runnable {   
 54   
 55         private Socket socket;   
 56         private BufferedReader in = null;   
 57         private String msg = "";   
 58   
 59         public Service(Socket socket) {   
 60             this.socket = socket;   
 61             try {   
 62                 in = new BufferedReader(new InputStreamReader(socket   
 63                         .getInputStream()));   
 64                 msg = "user:" + this.socket.getInetAddress() + " come total:"  
 65                         + mList.size();   
 66                 this.sendmsg();   
 67             } catch (IOException e) {   
 68                 e.printStackTrace();   
 69             }   
 70         }   
 71   
 72         public void run() {   
 73             // TODO Auto-generated method stub  
 74             try {   
 75                 while (true) {   
 76                     if ((msg = in.readLine()) != null) {   
 77                         if (msg.equals("exit")) {   
 78                             System.out.println("sssssssssss");   
 79                             mList.remove(socket);   
 80                             in.close();   
 81                             msg = "user:" + socket.getInetAddress()   
 82                                     + " exit total:" + mList.size();   
 83                             socket.close();   
 84                             this.sendmsg();   
 85                             break;   
 86                         } else {   
 87                             msg = socket.getInetAddress() + " : " + msg;   
 88                             this.sendmsg();   
 89                         }   
 90                     }   
 91   
 92                 }   
 93             } catch (Exception ex) {   
 94                 System.out.println("server 读取数据异常");   
 95                 ex.printStackTrace();   
 96             }   
 97         }   
 98   
 99         /**  
100          * 发送消息给所有客户端  
101          */  
102         public void sendmsg() {   
103             System.out.println(msg);   
104             int num = mList.size();   
105             for (int i = 0; i < num; i++) {   
106                 Socket mSocket = mList.get(i);   
107                 PrintWriter pout = null;   
108                 try {   
109                     pout = new PrintWriter(new BufferedWriter(   
110                             new OutputStreamWriter(mSocket.getOutputStream())),   
111                             true);   
112                     pout.println(msg);   
113                 } catch (IOException e) {   
114                     e.printStackTrace();   
115                 }   
116             }   
117         }   
118     }   
119 }


2.客户端程序：
  
  1.  package com.Aina.Android;  
  2. import java.io.BufferedReader;   
  3. import java.io.BufferedWriter;   
  4. import java.io.InputStreamReader;   
  5. import java.io.OutputStreamWriter;   
  6. import java.io.PrintWriter;   
  7. import java.net.Socket;   
  8.   
  9. import android.app.Activity;   
  10. import android.app.AlertDialog;   
  11. import android.content.DialogInterface;   
  12. import android.os.Bundle;   
  13. import android.os.Handler;   
  14. import android.os.Message;   
  15. import android.util.Log;   
  16. import android.view.View;   
  17. import android.widget.Button;   
  18. import android.widget.EditText;   
  19. import android.widget.TextView;   
  20.   
  21. public class Test extends Activity implements Runnable {   
  22.     /** Called when the activity is first created. */  
  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 = "192.168.0.132";   
  28.     private static final int PORT = 9999;   
  29.     private Socket socket = null;   
  30.     private BufferedReader in = null;   
  31.     private PrintWriter out = null;   
  32.     private String content = "";   
  33.   
  34.     @Override  
  35.     public void onCreate(Bundle savedInstanceState) {   
  36.         super.onCreate(savedInstanceState);   
  37.         setContentView(R.layout.main);   
  38.         tv_msg = (TextView) this.findViewById(R.id.TextView);   
  39.         ed_msg = (EditText) this.findViewById(R.id.EditText01);   
  40.         btn_login = (Button) this.findViewById(R.id.Button01);   
  41.         btn_send = (Button) this.findViewById(R.id.Button02);   
  42.         try {   
  43.             socket = new Socket(HOST, PORT);   
  44.             in = new BufferedReader(new InputStreamReader(socket   
  45.                     .getInputStream()));   
  46.             out = new PrintWriter(new BufferedWriter(   
  47.                     new OutputStreamWriter(socket.getOutputStream())),   
  48.                     true);   
  49.         } catch (Exception ex) {   
  50.             ex.printStackTrace();   
  51.             ShowDialog("登陆异常:" + ex.getMessage());   
  52.         }   
  53.         btn_send.setOnClickListener(new Button.OnClickListener() {   
  54.   
  55.             public void onClick(View v) {   
  56.                 // TODO Auto-generated method stub  
  57.                 String msg = ed_msg.getText().toString();   
  58.                 if (socket.isConnected()) {   
  59.                     if (!socket.isOutputShutdown()) {   
  60.                         out.println(msg);   
  61.                     }   
  62.                 }   
  63.             }   
  64.   
  65.         });   
  66.         new Thread(this).start();   
  67.     }   
  68.   
  69.     public void ShowDialog(String msg) {   
  70.         new AlertDialog.Builder(this).setTitle("提示").setMessage(msg)   
  71.                 .setPositiveButton("OK", new DialogInterface.OnClickListener() {   
  72.   
  73.                     public void onClick(DialogInterface dialog, int which) {   
  74.                         // TODO Auto-generated method stub  
  75.   
  76.                     }   
  77.   
  78.                 }).show();   
  79.     }   
  80.   
  81.     public void run() {   
  82.         try {   
  83.             while (true) {   
  84.                 if(socket.isConnected()){   
  85.                     if(!socket.isInputShutdown()){   
  86.                         if ((content = in.readLine()) != null) {   
  87.                             Log.i("TAG", "++ "+content);   
  88.                             content += "\n";   
  89.                             mHandler.sendMessage(mHandler.obtainMessage());   
  90.                         }else{   
  91.                                
  92.                         }   
  93.                     }   
  94.                 }   
  95.                    
  96.             }   
  97.         } catch (Exception ex) {   
  98.             ex.printStackTrace();   
  99.         }   
  100.     }   
  101.   
  102.     public Handler mHandler = new Handler() {   
  103.         public void handleMessage(Message msg) {   
  104.             super.handleMessage(msg);   
  105.             Log.i("TAG", "-- "+msg);   
  106.             tv_msg.setText(tv_msg.getText().toString() + content);   
  107.         }   
  108.     };   
  109. }  
【推广】 免费学中医，健康全家人
原文地址：https://www.cnblogs.com/qingblog/p/2607924.html