Android客户端与Eclipse服务器端的Socket通信

Server端代码

用来实现客户端socket的监听

package MyServer;

import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.Vector;

import javax.swing.JOptionPane;

public class MyServerSocket
{
    private Vector<ChatSocket> vector=new Vector<ChatSocket>();//存放所有的客户端socket
    public MyServerSocket()
    {
        try
        {
            ServerSocket serverSocket=new ServerSocket(13345);//服务端开启对端口13345的监听
            while(true)
            {
              Socket socket=serverSocket.accept();//服务器端提供与客户端相对应的socket
              JOptionPane.showMessageDialog(null, "已经有客户端连入");
              ChatSocket cs=new ChatSocket(socket,vector);//对每一个客户端都提供一个ChatSocket类来进行信息的交互
              add(cs);
              cs.start();
            }
        } catch (IOException e)
        {
            // TODO 自动生成的 catch 块
            e.printStackTrace();
        }
    }
    public void add(ChatSocket csSocket)//服务器端添加每一个客户端socket
    {
        vector.add(csSocket);
    }
    public static void main(String[]args)
    {
        new MyServerSocket();
    }
}

ChatSocket类，继承Thread线程类，进行与每个客户端进行信息交互的任务

package MyServer;

import java.io.BufferedOutputStream;
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.io.UnsupportedEncodingException;
import java.net.Socket;
import java.nio.Buffer;
import java.util.Vector;

import javax.swing.text.AbstractDocument.BranchElement;
/**
 * 
 * @author hcc
 *客户端与服务端进行信息交互的Chat类
 */
public class ChatSocket extends Thread
{
    Socket socket;
    Vector<ChatSocket>vector;
    public ChatSocket(Socket s,Vector<ChatSocket>vector)
    {
        this.socket=s;
        this.vector = vector;
    }
    public void out(String out)//服务器发送消息给客户端
    {
       try
    {
        BufferedWriter bfWriter = new BufferedWriter(new OutputStreamWriter(socket.getOutputStream()));
        bfWriter.write(out+"
");
        bfWriter.flush();//清空缓冲区，避免消息延迟显示
    } catch (UnsupportedEncodingException e)
    {
        // TODO 自动生成的 catch 块
        e.printStackTrace();
    } catch (IOException e)
    {
        // TODO 自动生成的 catch 块
        e.printStackTrace();
    }
    }
    @Override
    public void run()
    {
        try
        {
            BufferedReader bufferedReader=new BufferedReader(
                                                                     new InputStreamReader(
                                                                             socket.getInputStream()));
            String line = null;
            while((line=bufferedReader.readLine())!=null)//服务端接收客户端的消息
            {
                sendMessage(this, line);//转发给其他客户端
                System.out.println(line);
            }
            bufferedReader.close();
        } catch (IOException e)
        {
            // TODO 自动生成的 catch 块
            e.printStackTrace();
        }
    }
    public void sendMessage(ChatSocket cs,String out)
    {
        for(int i=0;i<vector.size();i++)
        {
            ChatSocket csChatSocket=vector.get(i);
            if(!cs.equals(csChatSocket))//将发送该消息的客户端除外
            {
                csChatSocket.out(out);
            }
        }
    }

}

android端的客户端代码

package com.hcc.mysocketclient;

import android.os.AsyncTask;
import android.support.v7.app.AppCompatActivity;
import android.os.Bundle;
import android.text.Editable;
import android.view.View;
import android.widget.Button;
import android.widget.EditText;
import android.widget.TextView;
import android.widget.Toast;

import java.io.BufferedInputStream;
import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.net.Socket;
import java.net.UnknownHostException;
import java.util.logging.SocketHandler;

public class MainActivity extends AppCompatActivity {
    Button conBtn;
    EditText ipText;
    Button sendBtn;
    EditText sendText;
    TextView textView;
    Socket clientSocket;
    BufferedReader bfReader;
    BufferedWriter bfWriter;
    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_main);
        findViews();
        conBtn.setOnClickListener(new View.OnClickListener() {
            @Override
            public void onClick(View v) {
                connect();
            }
        });
        sendBtn.setOnClickListener(new View.OnClickListener() {
            @Override
            public void onClick(View v) {
                send();
            }
        });
    }
    private void findViews(){
        conBtn = (Button)findViewById(R.id.con_btn);
        sendBtn = (Button)findViewById(R.id.send_btn);
        ipText = (EditText)findViewById(R.id.ip_text);
        sendText = (EditText)findViewById(R.id.send_text);
        textView = (TextView)findViewById(R.id.content_text);
    }
    private void connect(){
            AsyncTask<Void,String,Void> reader = new AsyncTask<Void, String, Void>() {
                @Override
                protected Void doInBackground(Void... params) {
                    try {
                        clientSocket = new Socket("10.62.37.152",13345);
                           //客户端建立与服务端socket的连接,"10.62.37.152"为我的局域网ip地址,读者按照自己的ip地址进行相应修改
                        bfWriter = new BufferedWriter(new OutputStreamWriter(clientSocket.getOutputStream()));
                        bfReader = new BufferedReader(new InputStreamReader(clientSocket.getInputStream()));
                    } catch (IOException e) {
                        e.printStackTrace();
                    }
                    try {
                        String line = "hello";
                        while((line = bfReader.readLine())!=null){
                              publishProgress(line);//接收从服务端转发来的消息
                        }
                    } catch (IOException e) {
                        Toast.makeText(getApplicationContext(),"读取消息失败",Toast.LENGTH_LONG).show();
                        e.printStackTrace();
                    }
                    return  null;
                }
                @Override
                protected void onProgressUpdate(String... values) {
                    textView.append("别人说:" + values[0] + "
");
                    super.onProgressUpdate(values);
                }
            };
            reader.execute();
    }
       //发送消息给服务端
    private void send(){
        try {
            textView.append("我说"+sendText.getText().toString()+"
");
            bfWriter.write(sendText.getText().toString() + "
");
            bfWriter.flush();
        } catch (IOException e) {
            Toast.makeText(getApplicationContext(),"无法建立连接",Toast.LENGTH_LONG).show();
            e.printStackTrace();
        }
    }
}

xml文件

<?xml version="1.0" encoding="utf-8"?>
<LinearLayout xmlns:android="http://schemas.android.com/apk/res/android"
    xmlns:tools="http://schemas.android.com/tools" android:layout_width="match_parent"
    android:layout_height="match_parent"
    android:orientation="vertical"
    tools:context=".MainActivity">
    <EditText
        android:id="@+id/ip_text"
        android:layout_width="match_parent"
        android:layout_height="wrap_content" />
    <Button
        android:id="@+id/con_btn"
        android:text="Connect"
        android:layout_width="wrap_content"
        android:layout_height="wrap_content" />
    <TextView
        android:layout_width="match_parent"
        android:layout_height="280dp"
        android:id="@+id/content_text"/>
    <EditText
        android:id="@+id/send_text"
        android:layout_width="match_parent"
        android:layout_height="wrap_content" />
    <Button
        android:text="send"
        android:id="@+id/send_btn"
        android:layout_width="match_parent"
        android:layout_height="wrap_content" />
</LinearLayout>

最后的效果图

客户端可开启两个及以上的虚拟机进行客户端的聊天