服務(wù)器端代碼：package mytable;import java.awt.event.ActionEvent;import java.awt.event.ActionListener;import java.io.BufferedReader;import java.io.BufferedWriter;import java.io.IOException;import java.io.InputStreamReader;import java.io.OutputStream;import java.io.OutputStreamWriter;import java.net.ServerSocket;import java.net.Socket;import javax.swing.JButton;import javax.swing.JFrame;import javax.swing.JTextArea;import javax.swing.JTextField;public class MyServer implements ActionListener { /** * 服務(wù)器端 * */ private Window window; private ServerSocket server; private static Socket socket; private JButton button; private static JTextArea area; private JTextField field;// private BufferedWriter writer; private OutputStream writer; private static BufferedReader reader; // 存放TextField中的字符串 private static String fromClient; public MyServer() { window = new Window("服務(wù)器："); button = window.getButton(); area = window.getJTextArea(); field = window.getTextField(); button.addActionListener(this); try { //監(jiān)聽端口5000 server = new ServerSocket(5000); System.out.println("服務(wù)器已創(chuàng)建，正在等待客戶端連接。。。"); socket = server.accept(); System.out.println("客戶端已連接"); //打開輸入輸出流 writer = socket.getOutputStream(); reader = new BufferedReader(new InputStreamReader( socket.getInputStream())); } catch (IOException e) { // TODO Auto-generated catch block e.printStackTrace(); try { socket.close(); } catch (IOException e1) { // TODO Auto-generated catch block e1.printStackTrace(); } } } public static void main(String[] args) throws InterruptedException { new MyServer(); // 創(chuàng)建線程去讀取客戶端發(fā)來的數(shù)據(jù) new Thread(new Runnable() { @Override public void run() { try { while (socket != null) { fromClient = reader.readLine(); area.append("客戶端：" + fromClient + '\n'); } } catch (IOException e) { // TODO Auto-generated catch block e.printStackTrace(); try { reader.close(); } catch (IOException e1) { // TODO Auto-generated catch block e1.printStackTrace(); } } } }).start(); } /** * 按鈕監(jiān)聽方法，點(diǎn)擊按鈕時(shí)觸發(fā)該方法。 * */ @Override public void actionPerformed(ActionEvent e) { String me = field.getText().toString() + '\n'; area.append("服務(wù)器：" + me); field.setText(""); try { writer.write(me.getBytes("utf-8")); //刷新輸出流 writer.flush(); } catch (IOException e1) { // TODO Auto-generated catch block e1.printStackTrace(); try { writer.close(); } catch (IOException e2) { // TODO Auto-generated catch block e2.printStackTrace(); } } }}客戶端代碼package com.example.client;import java.io.BufferedReader;import java.io.OutputStream;import java.net.Socket;import android.support.v7.app.ActionBarActivity;import android.support.v7.app.ActionBar;import android.support.v4.app.Fragment;import android.os.Bundle;import android.os.Handler;import android.view.LayoutInflater;import android.view.Menu;import android.view.MenuItem;import android.view.View;import android.view.ViewGroup;import android.widget.Button;import android.widget.EditText;import android.widget.TextView;import android.os.Build;import java.io.BufferedReader;import java.io.BufferedWriter;import java.io.IOException;import java.io.InputStream;import java.io.InputStreamReader;import java.io.OutputStream;import java.io.OutputStreamWriter;import java.net.Socket;import java.net.UnknownHostException;import android.os.Bundle;import android.os.Handler;import android.os.Looper;import android.os.Message;import android.support.v7.app.ActionBarActivity;import android.text.method.ScrollingMovementMethod;import android.util.Log;import android.view.Menu;import android.view.MenuItem;import android.view.View;import android.view.View.OnClickListener;import android.widget.Button;import android.widget.EditText;import android.widget.TextView;public class MainActivity extends ActionBarActivity { public EditText editText; public Button button; // 輸出流 public BufferedReader in; // 輸入流// private BufferedWriter out; //輸入流// private InputStream in; //輸出流 public OutputStream out; // 客戶端socket public Socket socket; // 顯示數(shù)據(jù) public TextView textView; // 用來存放要傳遞給客戶端的數(shù)據(jù) public static String data; //handler發(fā)送處理消息 public Handler handler; public String b; @Override public void onCreate(Bundle savedInstanceState) { super.onCreate(savedInstanceState); setContentView(R.layout.activity_main); editText = (EditText) findViewById(R.id.editText); button = (Button) findViewById(R.id.send); textView = (TextView) findViewById(R.id.textView); //設(shè)置textView可以滾動(dòng) textView.setMovementMethod(ScrollingMovementMethod.getInstance()); handler = new Handler(new Handler.Callback() { @Override public boolean handleMessage(Message msg) { if(msg.what == 0x1314) { textView.append("服務(wù)器：" + b + '\n'); } return true; } }); new Thread(new Runnable() { @Override public void run() { try { socket = new Socket("127.0.0.1", 5000); Log.e("--->", "已發(fā)出鏈接請(qǐng)求"); in = new BufferedReader(new InputStreamReader(socket.getInputStream())); out = socket.getOutputStream(); while (socket != null) { b = in.readLine();// textView.append("服務(wù)器：" + b + '\n'); handler.sendEmptyMessage(0x1314); } } catch (UnknownHostException e) { // TODO Auto-generated catch block e.printStackTrace(); } catch (IOException e) { // TODO Auto-generated catch block e.printStackTrace(); } } }).start(); button.setOnClickListener(new OnClickListener() { @Override public void onClick(View arg0) { data = editText.getText().toString(); textView.append("客戶端說：" + data + '\n'); editText.setText(""); try { if (socket != null) { out.write((data + '\n').getBytes("GBK")); out.flush(); } else ?if(socket==null) Log.e("--->", "服務(wù)器未連接，無法獲得輸出流"); } catch (IOException e) { e.printStackTrace(); } } }); }}