1.服务器程序：
Java代码
  1. package com;
  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;
  16. /**
  17. *comServer
  18. *
  19. *@authorAina.huangE-mail:674023920@qq.com
  20. *@version创建时间：2010Jul14,201010:45:35AM类说明
  21. */
  22. public class Main{
  24. private static final int PORT= 9999 ; //端口监听
  25. private List<Socket>mList= new ArrayList<Socket>(); //存放客户端socket
  26. private ServerSocketserver= null ;
  27. private ExecutorServicemExecutorService= null ; //线程池
  29. /**
  30. *@paramargs
  31. */
  32. public static void main(String[]args){
  33. //TODOAuto-generatedmethodstub
  34. new Main();
  35. }
  37. public Main(){
  38. try {
  39. server= new ServerSocket(PORT);
  40. mExecutorService=Executors.newCachedThreadPool(); //创建一个线程池
  41. System.out.println( "ServerStart..." );
  42. Socketclient= null ;
  43. while ( true ){
  44. client=server.accept();
  45. mList.add(client);
  46. mExecutorService.execute( new Service(client)); //开启一个客户端线程.
  47. }
  48. } catch (Exceptionex){
  49. ex.printStackTrace();
  50. }
  51. }
  53. public class Service implements Runnable{
  55. private Socketsocket;
  56. private BufferedReaderin= null ;
  57. private Stringmsg= "" ;
  59. public Service(Socketsocket){
  60. this .socket=socket;
  61. try {
  62. in= new BufferedReader( new InputStreamReader(socket
  63. .getInputStream()));
  64. msg= "user:" + this .socket.getInetAddress()+ "cometotal:"
  65. +mList.size();
  66. this .sendmsg();
  67. } catch (IOExceptione){
  68. e.printStackTrace();
  69. }
  70. }
  72. public void run(){
  73. //TODOAuto-generatedmethodstub
  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. + "exittotal:" +mList.size();
  83. socket.close();
  84. this .sendmsg();
  85. break ;
  86. } else {
  87. msg=socket.getInetAddress()+ ":" +msg;
  88. this .sendmsg();
  89. }
  90. }
  92. }
  93. } catch (Exceptionex){
  94. System.out.println( "server读取数据异常" );
  95. ex.printStackTrace();
  96. }
  97. }
  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. SocketmSocket=mList.get(i);
  107. PrintWriterpout= null ;
  108. try {
  109. pout= new PrintWriter( new BufferedWriter(
  110. new OutputStreamWriter(mSocket.getOutputStream())),
  111. true );
  112. pout.println(msg);
  113. } catch (IOExceptione){
  114. e.printStackTrace();
  115. }
  116. }
  117. }
  118. }
  119. }


2.客户端程序：
添加 android.permission.INTERNET
Java代码
  1. package com.Aina.Android;
  3. import java.io.BufferedReader;
  4. import java.io.BufferedWriter;
  5. import java.io.InputStreamReader;
  6. import java.io.OutputStreamWriter;
  7. import java.io.PrintWriter;
  8. import java.net.Socket;
  10. import android.app.Activity;
  11. import android.app.AlertDialog;
  12. import android.content.DialogInterface;
  13. import android.os.Bundle;
  14. import android.os.Handler;
  15. import android.os.Message;
  16. import android.util.Log;
  17. import android.view.View;
  18. import android.widget.Button;
  19. import android.widget.EditText;
  20. import android.widget.TextView;
  22. public class Test extends Activity implements Runnable{
  23. /**Calledwhentheactivityisfirstcreated.*/
  24. private TextViewtv_msg= null ;
  25. private EditTexted_msg= null ;
  26. private Buttonbtn_send= null ;
  27. private Buttonbtn_login= null ;
  28. private static final StringHOST= "192.168.0.132" ;
  29. private static final int PORT= 9999 ;
  30. private Socketsocket= null ;
  31. private BufferedReaderin= null ;
  32. private PrintWriterout= null ;
  33. private Stringcontent= "" ;
  35. @Override
  36. public void onCreate(BundlesavedInstanceState){
  37. super .onCreate(savedInstanceState);
  38. setContentView(R.layout.main);
  39. tv_msg=(TextView) this .findViewById(R.id.TextView);
  40. ed_msg=(EditText) this .findViewById(R.id.EditText01);
  41. btn_login=(Button) this .findViewById(R.id.Button01);
  42. btn_send=(Button) this .findViewById(R.id.Button02);
  43. try {
  44. socket= new Socket(HOST,PORT);
  45. in= new BufferedReader( new InputStreamReader(socket
  46. .getInputStream()));
  47. out= new PrintWriter( new BufferedWriter(
  48. new OutputStreamWriter(socket.getOutputStream())),
  49. true );
  50. } catch (Exceptionex){
  51. ex.printStackTrace();
  52. ShowDialog( "登陆异常:" +ex.getMessage());
  53. }
  54. btn_send.setOnClickListener( new Button.OnClickListener(){
  56. public void onClick(Viewv){
  57. //TODOAuto-generatedmethodstub
  58. Stringmsg=ed_msg.getText().toString();
  59. if (socket.isConnected()){
  60. if (!socket.isOutputShutdown()){
  61. out.println(msg);
  62. }
  63. }
  64. }
  66. });
  67. new Thread( this ).start();
  68. }
  70. public void ShowDialog(Stringmsg){
  71. new AlertDialog.Builder( this ).setTitle( "提示" ).setMessage(msg)
  72. .setPositiveButton( "OK" , new DialogInterface.OnClickListener(){
  74. public void onClick(DialogInterfacedialog, int which){
  75. //TODOAuto-generatedmethodstub
  77. }
  79. }).show();
  80. }
  82. public void run(){
  83. try {
  84. while ( true ){
  85. if (socket.isConnected()){
  86. if (!socket.isInputShutdown()){
  87. if ((content=in.readLine())!= null ){
  88. Log.i( "TAG" , "++" +content);
  89. content+= "/n" ;
  90. mHandler.sendMessage(mHandler.obtainMessage());
  91. } else {
  93. }
  94. }
  95. }
  97. }
  98. } catch (Exceptionex){
  99. ex.printStackTrace();
  100. }
  101. }
  103. public HandlermHandler= new Handler(){
  104. public void handleMessage(Messagemsg){
  105. super .handleMessage(msg);
  106. Log.i( "TAG" , "--" +msg);
  107. tv_msg.setText(tv_msg.getText().toString()+content);
  108. }
  109. };
  110. }


Java代码
  1. <?xmlversion= "1.0" encoding= "utf-8" ?>
  2. <LinearLayoutxmlns:android= "http://schemas.android.com/apk/res/android"
  3. android:orientation= "vertical" android:layout_width= "fill_parent"
  4. android:layout_height= "fill_parent" >
  5. <TextViewandroid:id= "@+id/TextView" android:singleLine= "false"
  6. android:layout_width= "fill_parent"
  7. android:layout_height= "wrap_content" />
  8. <EditTextandroid:hint= "content" android:id= "@+id/EditText01"
  9. android:layout_width= "fill_parent"
  10. android:layout_height= "wrap_content" >
  11. </EditText>
  12. <Buttonandroid:text= "login" android:id= "@+id/Button01"
  13. android:layout_width= "fill_parent"
  14. android:layout_height= "wrap_content" >
  15. </Button>
  16. <Buttonandroid:text= "send" android:id= "@+id/Button02"
  17. android:layout_width= "fill_parent"
  18. android:layout_height= "wrap_content" >
  19. </Button>
  20. </LinearLayout>

更多相关文章

  1. android亮屏、暗屏、解锁、关闭系统对话的监听事件
  2. SharedPreferences 源码分析
  3. Android中开关按钮IOS效果的实现
  4. Android(安卓)监听网络变化然后刷新页面
  5. Android(安卓)studio爬取网页
  6. Android的线程使用来更新UI----Thread、Handler、Looper、TimerT
  7. eclipse中Android布局的基本操作
  8. Android异步消息处理机制完全解析-Handler详解
  9. Android中Handler Runnable与Thread的区别详解

随机推荐

  1. React Native
  2. Ubuntu 10.04不能连接到HTC G1设备
  3. android webview 缩放及换行
  4. Android读取资源文件夹里的string-array
  5. Android(安卓)Weekly - 第 182 期
  6. RK3288 android7.1.2 android studio 用
  7. android MIME文件类型
  8. android程序入口
  9. Android(安卓)SDK 更新问题
  10. Android获取当前时间的android.text.form