Android Socket网络通信

1.服务器程序：

package com;

import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

/**
 * com Server
 * 
 * @author Aina.huang E-mail: [e-mail]
 * @version 创建时间：2010 Jul 14, 2010 10:45:35 AM 类说明
 */
public class Main {

	private static final int PORT = 9999;// 端口监听
	private List<Socket> mList = new ArrayList<Socket>();// 存放客户端socket
	private ServerSocket server = null;
	private ExecutorService mExecutorService = null;// 线程池

	/**
	 * @param args
	 */
	public static void main(String[] args) {
		// TODO Auto-generated method stub
		new Main();
	}

	public Main() {
		try {
			server = new ServerSocket(PORT);
			mExecutorService = Executors.newCachedThreadPool();// 创建一个线程池
			System.out.println("Server Start...");
			Socket client = null;
			while (true) {
				client = server.accept();
				mList.add(client);
				mExecutorService.execute(new Service(client));// 开启一个客户端线程.
			}
		} catch (Exception ex) {
			ex.printStackTrace();
		}
	}

	public class Service implements Runnable {

		private Socket socket;
		private BufferedReader in = null;
		private String msg = "";

		public Service(Socket socket) {
			this.socket = socket;
			try {
				in = new BufferedReader(new InputStreamReader(socket
						.getInputStream()));
				msg = "user:" + this.socket.getInetAddress() + " come total:"
						+ mList.size();
				this.sendmsg();
			} catch (IOException e) {
				e.printStackTrace();
			}
		}

		public void run() {
			// TODO Auto-generated method stub
			try {
				while (true) {
					if ((msg = in.readLine()) != null) {
						if (msg.equals("exit")) {
							System.out.println("sssssssssss");
							mList.remove(socket);
							in.close();
							msg = "user:" + socket.getInetAddress()
									+ " exit total:" + mList.size();
							socket.close();
							this.sendmsg();
							break;
						} else {
							msg = socket.getInetAddress() + " : " + msg;
							this.sendmsg();
						}
					}

				}
			} catch (Exception ex) {
				System.out.println("server 读取数据异常");
				ex.printStackTrace();
			}
		}

		/**
		 * 发送消息给所有客户端
		 */
		public void sendmsg() {
			System.out.println(msg);
			int num = mList.size();
			for (int i = 0; i < num; i++) {
				Socket mSocket = mList.get(i);
				PrintWriter pout = null;
				try {
					pout = new PrintWriter(new BufferedWriter(
							new OutputStreamWriter(mSocket.getOutputStream())),
							true);
					pout.println(msg);
				} catch (IOException e) {
					e.printStackTrace();
				}
			}
		}
	}
}

2.客户端程序：

package com.Aina.Android;

import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.io.PrintWriter;
import java.net.Socket;

import android.app.Activity;
import android.app.AlertDialog;
import android.content.DialogInterface;
import android.os.Bundle;
import android.os.Handler;
import android.os.Message;
import android.util.Log;
import android.view.View;
import android.widget.Button;
import android.widget.EditText;
import android.widget.TextView;

public class Test extends Activity implements Runnable {
	/** Called when the activity is first created. */
	private TextView tv_msg = null;
	private EditText ed_msg = null;
	private Button btn_send = null;
	private Button btn_login = null;
	private static final String HOST = "192.168.0.132";
	private static final int PORT = 9999;
	private Socket socket = null;
	private BufferedReader in = null;
	private PrintWriter out = null;
	private String content = "";

	@Override
	public void onCreate(Bundle savedInstanceState) {
		super.onCreate(savedInstanceState);
		setContentView(R.layout.main);
		tv_msg = (TextView) this.findViewById(R.id.TextView);
		ed_msg = (EditText) this.findViewById(R.id.EditText01);
		btn_login = (Button) this.findViewById(R.id.Button01);
		btn_send = (Button) this.findViewById(R.id.Button02);
		try {
			socket = new Socket(HOST, PORT);
			in = new BufferedReader(new InputStreamReader(socket
					.getInputStream()));
			out = new PrintWriter(new BufferedWriter(
					new OutputStreamWriter(socket.getOutputStream())),
					true);
		} catch (Exception ex) {
			ex.printStackTrace();
			ShowDialog("登陆异常:" + ex.getMessage());
		}
		btn_send.setOnClickListener(new Button.OnClickListener() {

			public void onClick(View v) {
				// TODO Auto-generated method stub
				String msg = ed_msg.getText().toString();
				if (socket.isConnected()) {
					if (!socket.isOutputShutdown()) {
						out.println(msg);
					}
				}
			}

		});
		new Thread(this).start();
	}

	public void ShowDialog(String msg) {
		new AlertDialog.Builder(this).setTitle("提示").setMessage(msg)
				.setPositiveButton("OK", new DialogInterface.OnClickListener() {

					public void onClick(DialogInterface dialog, int which) {
						// TODO Auto-generated method stub

					}

				}).show();
	}

	public void run() {
		try {
			while (true) {
				if(socket.isConnected()){
					if(!socket.isInputShutdown()){
						if ((content = in.readLine()) != null) {
							Log.i("TAG", "++ "+content);
							content += "\n";
							mHandler.sendMessage(mHandler.obtainMessage());
						}else{
							
						}
					}
				}
				
			}
		} catch (Exception ex) {
			ex.printStackTrace();
		}
	}

	public Handler mHandler = new Handler() {
		public void handleMessage(Message msg) {
			super.handleMessage(msg);
			Log.i("TAG", "-- "+msg);
			tv_msg.setText(tv_msg.getText().toString() + content);
		}
	};
}

<?xml version="1.0" encoding="utf-8"?>
<LinearLayout xmlns:android="http://schemas.android.com/apk/res/android"
	android:orientation="vertical" android:layout_width="fill_parent"
	android:layout_height="fill_parent">
	<TextView android:id="@+id/TextView" android:singleLine="false"
		android:layout_width="fill_parent"
		android:layout_height="wrap_content" />
	<EditText android:hint="content" android:id="@+id/EditText01"
		android:layout_width="fill_parent"
		android:layout_height="wrap_content">
	</EditText>
	<Button android:text="login" android:id="@+id/Button01"
		android:layout_width="fill_parent"
		android:layout_height="wrap_content">
	</Button>
	<Button android:text="send" android:id="@+id/Button02"
		android:layout_width="fill_parent"
		android:layout_height="wrap_content">
	</Button>
</LinearLayout>

评论

8 楼 hao123xue456 2011-11-21  

，好好学习一下

7 楼 tian_lan123 2010-12-30  

传输文本，效率极低

6 楼 wangshiming88 2010-12-24  

不敢看

5 楼 jacky_java 2010-11-11  

云里雾里 不实用

4 楼 hezhou_0521 2010-11-10  

请问，该服务端是怎么启动的呢？如果服务端没有启动，客户端连不上，就会报connection refuse。

3 楼 hezhou_0521 2010-11-09  

好文章啊,我一定顶啊.

2 楼 nbtlxx 2010-10-24  

顶一个顶一个顶一个顶一个

1 楼 cheng830306 2010-09-03  

沙发。。。。。。。好文章竟然没人顶。。。。。。。。。。