以聊天为例讲解关于Android_的socket编程.doc

关于Android 的socket编程【以聊天为例】下面，用敲门的方式演示Android如何实现套接字的通信。本例实现功能如下：Server端开启服务Client端发起链接请求，并向Server端发送数据Server端响应请求，并在Server显示，向Client端返回数据Client端接收Server的数据并显示本例效果如下：终端1：终端2：Server端：本例源代码如下：Server端：package com.android.Yao;import java.io.BufferedReader;import java.io.BufferedWriter;import java.io.IOException;import java.io.InputStreamReader;import java.io.OutputStreamWriter;import .ServerSocket;import .Socket;public class YaoChatServer extends Thread private YaoChatServer() throws IOException CreateSocket();/创建Socket服务器 public void run() Socket client;String txt;try while (true)/线程无限循环，实时监听socket端口client=ResponseSocket(); /响应客户端链接请求。while(true)txt=ReceiveMsg(client); System.out.println(txt);/链接获得客户端发来消息，并将其显示在Server端的屏幕上SendMsg(client,txt);/向客户端返回消息if(true)break;/中断，继续等待链接请求CloseSocket(client);/关闭此次链接 catch (IOException e) System.out.println(e);private ServerSocket server = null;private static final int PORT = 5000;private BufferedWriter writer;private BufferedReader reader;private void CreateSocket() throws IOExceptionserver = new ServerSocket(PORT, 100);System.out.println(Server starting.); private Socket ResponseSocket() throws IOExceptionSocket client = server.accept(); System.out.println(client connected.);return client;private void CloseSocket(Socket socket) throws IOExceptionreader.close();writer.close();socket.close();System.out.println(client closed.);private void SendMsg(Socket socket,String Msg) throws IOException writer = new BufferedWriter(new OutputStreamWriter(socket.getOutputStream();writer.write(Msg+n);writer.flush();private String ReceiveMsg(Socket socket) throws IOExceptionreader = new BufferedReader(new InputStreamReader(socket.getInputStream(); System.out.println(server get input from client socket.);String txt=Sever send:+reader.readLine();return txt;public static void main(final String args) throws IOException YaoChatServer yaochatserver = new YaoChatServer();if (yaochatserver != null) yaochatserver.start();Client端：package com.android.Yao;import java.io.BufferedReader;import java.io.BufferedWriter;import java.io.IOException;import .UnknownHostException;import java.io.InputStreamReader;import java.io.OutputStreamWriter;import .Socket;import android.app.Activity;import android.os.Bundle;import android.view.View;import android.widget.*;public class YaoChatRoomAndroid extends Activity /* Called when the activity is first created. */Overridepublic void onCreate(Bundle savedInstanceState) super.onCreate(savedInstanceState);setContentView(R.layout.chatroom);findviews();setonclick();private EditText chattxt;private TextView chattxt2;private Button chatok;public void findviews()chattxt = (EditText)this.findViewById(R.id.chattxt);chattxt2 = (TextView)this.findViewById(R.id.chattxt2);chatok = (Button)this.findViewById(R.id.chatOk);private void setonclick()chatok.setOnClickListener(new View.OnClickListener() Overridepublic void onClick(View v) try connecttoserver(chattxt.getText().toString(); catch (UnknownHostException e) / TODO Auto-generated catch blocke.printStackTrace(); catch (IOException e) / TODO Auto-generated catch blocke.printStackTrace(););public void connecttoserver(String socketData) throws UnknownHostException, IOExceptionSocket socket=RequestSocket(07,5000);SendMsg(socket,socketData); String txt = ReceiveMsg(socket);this.chattxt2.setText(txt); private Socket RequestSocket(String host,int port) throws UnknownHostException, IOException Socket socket = new Socket(host, port);return socket;private void SendMsg(Socket socket,String msg) throws IOExceptionBufferedWriter writer = new BufferedWriter(new OutputStreamWriter(socket.getOutputStream();writer.write(msg.replace(n, )+n);writer.fl