server端代碼：

public static void main(String[] args) { String address = ""; try { InetAddress ip4 = Inet4Address.getLocalHost(); address = ip4.getHostAddress(); System.out.println("本機(jī)地址：" + address); } catch (Exception e) { System.out.println("本機(jī)地址：" + e.getMessage()); } Scanner s = new Scanner(System.in); int port = s.nextInt(); s.close(); try { ExecutorService service = Executors.newFixedThreadPool(100); ServerSocket ss = new ServerSocket(port); System.out.println("服務(wù)器啟動(dòng)成功"+Thread.activeCount()); while (true) { try { service.submit(new SKRunnable(ss.accept())); } catch (Exception e) { System.out.println("服務(wù)器異常關(guān)閉"+e.getMessage()); break; } } ss.close(); System.out.println("服務(wù)器已關(guān)閉"); }catch (Exception e) { System.out.println("服務(wù)器啟動(dòng)失?。? + e.getMessage()); } }

public class SKRunnable implements Runnable { public static final String encode = "GB18030"; public SKRunnable(Socket socket) { this.socket = socket; } private Socket socket; private DataInputStream dataInputStream; private DataOutputStream dataOutputStream; private Thread readThread; private String client = ""; @Override public void run() { try { client = socket.getInetAddress().getHostAddress() + ":" + socket.getPort(); dataInputStream = new DataInputStream(socket.getInputStream()); dataOutputStream = new DataOutputStream(socket.getOutputStream()); push("連接到服務(wù)器成功"); readThread = new Thread() { @Override public void run() { while (true) { try { byte b = dataInputStream.readByte(); int len = dataInputStream.readInt(); byte[] data = new byte[len - 5]; dataInputStream.readFully(data); String receiverStr = new String(data, encode); String sysoStr = "【客戶端" + client + "】\n發(fā)來內(nèi)容：" + receiverStr + "\n長(zhǎng)度：" + len + "，類型：" + b; System.out.println(sysoStr); long current = System.currentTimeMillis(); if(current % 2 ==0) { push("讓我想想該怎么回你......"); sleep(1500); } push(getResponse(current)); } catch (Exception e) { System.out.println("與客戶端【" + client + "】斷開連接：" + e.getMessage()); System.gc(); break; } } } }; readThread.start(); } catch (Exception e) { System.out.println(Thread.activeCount() + "連接失敗2" + e.getMessage()); } } private void push(String content) { try { int type = 1; byte[] data = content.getBytes(encode); int len = data.length + 5; dataOutputStream.writeByte(type); dataOutputStream.writeInt(len); dataOutputStream.write(data); dataOutputStream.flush(); System.out.println("To Client【"+client+"】："+content); } catch (Exception e) { System.out.println("push:" + e.getMessage()); } } private String getResponse(long cuurent) { String code = String.valueOf(cuurent); code = code.substring(code.length() - 1); int index = MyUtils.toInt(code); switch (index) { case 0: code = "你在干什么？"; break; case 1: code = "你無不無聊？"; break; case 2: code = "你看你一天天的"; break; case 3: code = "你就不能正經(jīng)點(diǎn)？"; break; case 4: code = "你好意思嗎"; break; case 5: code = "快點(diǎn)閉嘴，什么都別說了"; break; case 6: code = "你好漂亮，好好看"; break; case 7: code = "今天天氣不錯(cuò)哈"; break; case 8: code = "我要準(zhǔn)備爆炸了，你快走?。?！"; break; case 9: code = "你以為你是誰？"; break; default: code = "我們懵逼了"; break; } return code; } }

app端代碼：

package com.lkl.linc.socketapp.server;import android.text.TextUtils;import com.lkl.linc.socketapp.utils.LG;import java.io.DataInputStream;import java.io.DataOutputStream;import java.net.Socket;import java.util.ArrayList;import java.util.List;public class SKUtils { private static SKUtils i; public static SKUtils get() { if (i == null) { synchronized (SKUtils.class) { if (i == null) { i = new SKUtils(); } } } return i; } private List<SKSet.OnSKListener> listListener = new ArrayList<>(); private Socket socket; private DataInputStream dataInputStream; private DataOutputStream dataOutputStream; private Thread readThread; public void startConn() { new Thread() { @Override public void run() { disConn(); try { sleep(50); } catch (InterruptedException e) { e.printStackTrace(); } try { socket = new Socket(ServerUtils.ip(), ServerUtils.port()); socket.setKeepAlive(true); dataInputStream = new DataInputStream(socket.getInputStream()); dataOutputStream = new DataOutputStream(socket.getOutputStream()); readThread = new Thread() { @Override public void run() { while (true) { try { byte b = dataInputStream.readByte(); int len = dataInputStream.readInt(); byte[] data = new byte[len - 5]; dataInputStream.readFully(data); String receiverStr = new String(data, SKSet.encode); if (!TextUtils.isEmpty(receiverStr)) { callBackResult(receiverStr); } LG.i("服務(wù)器消息：類型" + b + "，長(zhǎng)度：" + len + "，內(nèi)容：" + receiverStr); } catch (Exception e) { callBackError("服務(wù)器服務(wù)器斷開連接"); readThread = null; dataReset(); LG.e("readThread:" + e.getMessage()); break; } } } }; readThread.start(); callBackResult("服務(wù)器連接成功"); } catch (Exception e) { callBackError("服務(wù)器連接失敗2" + e.getMessage()); LG.e("startConn:" + e.getMessage()); } } }.start(); } public void sendMsg(String content, SKSet.OnSKListener listener) { new Thread() { @Override public void run() { try { if (push(content)) { listener.onResult("發(fā)送成功"); } else { listener.onFailed("發(fā)送失敗"); } } catch (Exception e) { listener.onFailed("發(fā)送失敗" + e.getMessage()); LG.e("sendMsg：" + e.getMessage()); } } }.start(); } private boolean push(String content) { try { int type = 1; byte[] data = content.getBytes(SKSet.encode); int len = data.length + 5; dataOutputStream.writeByte(type); dataOutputStream.writeInt(len); dataOutputStream.write(data); dataOutputStream.flush(); return true; } catch (Exception e) { System.out.println("push:" + e.getMessage()); return false; } } private void dataReset() { if (socket != null) { socket = null; } if (dataInputStream != null) { dataInputStream = null; } if (dataOutputStream != null) { dataOutputStream = null; } } public void disConn() { new Thread() { @Override public void run() { try { if (socket != null) { try { dataInputStream.close(); dataOutputStream.close(); } catch (Exception e) { LG.e("Stream:" + e.getMessage()); } try { if (!socket.isClosed()) { socket.close(); socket.shutdownOutput(); } } catch (Exception e) { LG.e("socket:" + e.getMessage()); } dataReset(); System.gc(); callBackResult("斷開成功"); } } catch (Exception e) { LG.e(e.getMessage()); callBackError("斷開失敗，" + e.getMessage()); } } }.start(); } private void callBackResult(String str) { for (SKSet.OnSKListener l : listListener) { try { l.onResult(str); } catch (Exception e) { LG.e(e.getMessage()); } } } private void callBackError(String error) { for (SKSet.OnSKListener l : listListener) { try { l.onFailed(error); } catch (Exception e) { LG.e(e.getMessage()); } } } public void addListener(SKSet.OnSKListener listener) { if (!listListener.contains(listener)) { listListener.add(listener); } } public void removeListener(SKSet.OnSKListener listener) { listListener.remove(listener); }}

這是只是臨時(shí)記錄下來的代碼，基本上沒怎么優(yōu)化。不喜勿噴。