Android Socket实现多个客户端即时通信聊天

*/ public class Server {

static List cons = new LinkedList();private static Socket socket = null;

public static class ServerThread extends Thread{private Socket s;

public ServerThread(Socket socket){this.s = socket;cons.add(s);}

@Override public void run(){System.out.print("新用户加入\n");System.out.print("当前在线数量："+cons.size()+"\n");try{while(true){

BufferedReader br = new BufferedReader(new InputStreamReader(s.getInputStream()));String mess;// = br.readLine();//保存信息if((mess=br.readLine())!=null) {if(mess.equals("-用户退出-")){s.close();}System.out.print("客户端：" + mess + "\n");BufferedWriter bw = new BufferedWriter(new OutputStreamWriter(s.getOutputStream()));//为了证明是服务器返回的数据，我对mess修改在发送到客户端//这里修改广播到所有客户端for (Socket so : cons){BufferedWriter buffw = new BufferedWriter(new OutputStreamWriter(so.getOutputStream()));String str = "服务器>>"+mess+"\n";buffw.write(str);buffw.flush();}////单客户端通信/*String str = "服务器>>"+mess+"\n";bw.write(str);bw.flush();*/}}}catch (IOException e){System.out.print("用户退出！\n");cons.remove(s);e.printStackTrace();this.interrupt();//e.printStackTrace();}catch (NullPointerException e) {System.out.print("NullPointerException");}finally {try {s.close();}catch (IOException e){System.out.print("IOException-2");e.printStackTrace();}}}

}

public static void main(String[] args) throws IOException {

@Override protected void onCreate(Bundle savedInstanceState) {super.onCreate(savedInstanceState);setContentView(R.layout.activity_chat_room);

Intent intent = getIntent();name = intent.getStringExtra("name");Log.d("孔昊",name);

//从服务器读数进程new Thread(new Runnable() {private String msg_get="";@Override public void run() {try {socket = new Socket();socket.connect(new InetSocketAddress("公网IP", 30001), 5000);

//input BufferedReader br = new BufferedReader(new InputStreamReader(socket.getInputStream()));

while((msg_get=br.readLine())!=null){Message message = new Message();Bundle bundle = new Bundle();Log.d("孔昊",msg_get);bundle.putString("msg",msg_get);message.setData(bundle);message.what = UPDATE;handler.sendMessage(message);}

}catch (IOException e){e.printStackTrace();}}}).start();

edit = (EditText) findViewById(R.id.edit);send = (Button) findViewById(R.id.send);send.setOnClickListener(this);disconnect = (Button) findViewById(R.id.disconnect);disconnect.setOnClickListener(this);

msg_recyclerView = (RecyclerView) findViewById(R.id.msg_view);LinearLayoutManager linearLayoutManager = new LinearLayoutManager(this);msg_recyclerView.setLayoutManager(linearLayoutManager);adapter = new MsgAdapter(msgs);msg_recyclerView.setAdapter(adapter);}

Handler handler = new Handler(){

@Override public void handleMessage(Message msg){super.handleMessage(msg);switch (msg.what){//更新消息列表case UPDATE:{Bundle bundle = msg.getData();String msg_get = bundle.getString("msg");Msg msg1 = new Msg(msg_get);msgs.add(msg1);adapter.notifyDataSetChanged();}break;}}};

//向服务器发数据进程class SocketThread extends Thread{private String msg;//Socket socket;

public SocketThread(String m){msg = m;}

@Override public void run(){try {

BufferedWriter bw = new BufferedWriter(new OutputStreamWriter(socket.getOutputStream()));bw.write(msg);bw.newLine();bw.flush();

}catch (IOException e){e.printStackTrace();}}

}

@Override public void onClick(View v) {switch(v.getId()){case R.id.send:{String s = name +":"+ edit.getText().toString();edit.setText("");new Thread(new SocketThread(s)).start();}break;case R.id.disconnect:{try {//socket.shutdownOutput();//socket.shutdownInput();//socket.close();BufferedWriter bw = new BufferedWriter(new OutputStreamWriter(socket.getOutputStream()));bw.write("-用户退出-");bw.newLine();bw.flush();//发送message,更新UI Message message = new Message();Bundle bundle = new Bundle();bundle.putString("msg","你已经退出聊天！");message.setData(bundle);message.what = UPDATE;handler.sendMessage(message);

}catch (IOException e){//Log.d("孔昊","断开连接");e.printStackTrace();}}break;}}

//back事件

@Override public void onBackPressed(){try {BufferedWriter bw = new BufferedWriter(new OutputStreamWriter(socket.getOutputStream()));bw.write("-用户退出-");bw.newLine();bw.flush();

}catch (IOException e){e.printStackTrace();}super.onBackPressed();}

*/ public class Client {private static String name;private static Socket socket;public static void main(String[] args) {try {name = "孔昊";Socket s = new Socket("112.74.92.125",30001);socket = s;System.out.println("客户端IP:"+s.getLocalAddress()+"端口"+s.getPort());//构建IO流BufferedWriter bw = new BufferedWriter(new OutputStreamWriter(s.getOutputStream()));

//建立键盘输入：

Scanner scanner = new Scanner(System.in);while(true){System.out.println("请输入发送消息内容：");bw.write(name+":"+scanner.nextLine()+"\n");bw.newLine();bw.flush();BufferedReader br = new BufferedReader(new InputStreamReader(s.getInputStream()));//读取服务器返回的消息数据System.out.println(s.getInetAddress().getLocalHost()+":"+s.getPort()+">>"+br.readLine());}

} catch (UnknownHostException e) {e.printStackTrace();} catch (IOException e) {e.printStackTrace();}finally {try{socket.close();}catch (IOException e){e.printStackTrace();}}