Android 使用Socket實現伺服器與手機客戶端的長連線八
阿新 • • 發佈：2019-01-09
一、傳送請求的資訊：
1、介面
public interface Request {
String getData();
}2、文字請求：
public class TextRequest implements Request{
private Map<String, String> map = new HashMap<String, String>();
public TextRequest(String sender, String token, String receiver, String content) {
map.put("type" 3、認證請求：
public class AuthRequest implements Request{
private Map<String, String> map = new HashMap<String, String>();
public AuthRequest(String sender, String token){
map.put("type", "request");
map.put("sequence", UUID.randomUUID().toString());
map.put("action" 二、建立聯結器
public class Connector {
protected static final String dstName = "192.168.0.20";
protected static final int dstPort = 9999;
private Socket mSocket;
public Connector(){
}
//-單例-----------------------------------------------
private static Connector instance;
public static Connector getInstance() {
if (instance == null) {
synchronized (Connector.class) {
if (instance == null) {
instance = new Connector();
}
}
}
return instance;
}
//-監聽-----------------------------------
protected ConnectorListener mListener;
public void setConnectorListener(ConnectorListener listener) {
this.mListener = listener;
}
public interface ConnectorListener {
void pushData(String data);
}
public void connect(){
try {
if (mSocket == null || mSocket.isClosed()) {
mSocket = new Socket(dstName, dstPort);
}
//傳送資料
new Thread(new RequestWorker()).start();
//接受資料
new Thread(new ReceiveWorker()).start();
} catch (UnknownHostException e) {
e.printStackTrace();
} catch (IOException e) {
e.printStackTrace();
}
}
//-一般使用這個方法----------------------------------------------------
public void connect(AuthRequest auth){
connect();
putRequest(auth);
}
private ArrayBlockingQueue<String> queue = new ArrayBlockingQueue<String>(8);
private class RequestWorker implements Runnable{
@Override
public void run() {
OutputStream out = null;
try {
out = mSocket.getOutputStream();
while(true){
String content = queue.take();
out.write(content.getBytes());
}
} catch (IOException e) {
e.printStackTrace();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
public void putRequest(String content){
try {
queue.put(content);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
public void putRequest(Request request) {
putRequest(request.getData());
}
private class ReceiveWorker implements Runnable{
@Override
public void run() {
try {
InputStream inputStream = mSocket.getInputStream();
byte[] buffer = new byte[1024];
int len = -1;
while((len = inputStream.read(buffer))!=-1){
String text = new String(buffer, 0, len);
if (mListener !=null) {
mListener.pushData(text);
}
}
} catch (IOException e) {
e.printStackTrace();
}
}
}
public void disConn(){
try {
if (mSocket != null && !mSocket.isClosed()) {
mSocket.close();
mSocket = null;
}
} catch (IOException e) {
e.printStackTrace();
}
}
}三、建立服務，在後臺不斷的傳送廣播
public class CoreService extends Service implements ConnectorListener{
private Connector connector;
private ExecutorService mPools;
@Override
public IBinder onBind(Intent intent) {
return null;
}
@Override
public void onCreate() {
super.onCreate();
connector = Connector.getInstance();
connector.setConnectorListener(this);
mPools = Executors.newFixedThreadPool(3);
mPools.execute(new Runnable() {
@Override
public void run() {
AuthRequest request = null;
if (Build.VERSION.SDK_INT > Build.VERSION_CODES.HONEYCOMB) {
request = new AuthRequest("B", "B");
} else {
request = new AuthRequest("A", "A");
}
connector.connect(request);
}
});
}
@Override
public void pushData(String data) {
Intent intent = new Intent();
intent.setAction(PushReceiver.ACTION_TEXT);
intent.putExtra(PushReceiver.DATA_KEY, data);
//使用廣播的形式把資料傳送到主介面進行處理
sendBroadcast(intent);
}
}廣播類：
public abstract class PushReceiver extends BroadcastReceiver {
public static final String ACTION_TEXT = "com.android.action.text";
public static final String DATA_KEY = "data";
}四、主介面的實現：
public class MainActivity extends ActionBarActivity {
private EditText mEtContent;
@Override
protected void onCreate(Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
setContentView(R.layout.activity_main);
mEtContent = (EditText) findViewById(R.id.edit_query);
startService(new Intent(this, CoreService.class));
}
public void sendMsg(View view){
String content = mEtContent.getText().toString();
if (TextUtils.isEmpty(content)) {
return;
}
String sender = null;
String token = null;
String receiver = null;
if (Build.VERSION.SDK_INT > Build.VERSION_CODES.HONEYCOMB_MR2) {
sender = "B";
receiver = "A";
token = "B";
}else {
sender = "A";
token = "A";
receiver = "B";
}
Request request = new TextRequest(sender, token, receiver, content);
Connector.getInstance().putRequest(request);
}
@Override
protected void onResume() {
super.onResume();
if (mReceiver != null) {
IntentFilter filter = new IntentFilter(PushReceiver.ACTION_TEXT);
registerReceiver(mReceiver, filter);
}
}
private PushReceiver mReceiver = new PushReceiver() {
@Override
public void onReceive(Context context, Intent intent) {
String action = intent.getAction();
if (PushReceiver.ACTION_TEXT.equals(action)) {
String result = intent.getStringExtra(PushReceiver.DATA_KEY);
Toast.makeText(getApplicationContext(), result,
Toast.LENGTH_SHORT).show();
}
}
};
@Override
protected void onDestroy() {
super.onDestroy();
if (mReceiver != null) {
unregisterReceiver(mReceiver);
}
}
}五、伺服器類
public class TCPServer {
private static Map<String, Socket> clients = new LinkedHashMap<String, Socket>();
public static void main(String[] args) {
try {
ServerSocket server = new ServerSocket();
while(true){
final Socket client = server.accept();
new Thread(new Runnable() {
@Override
public void run() {
try {
InputStream inputStream = client.getInputStream();
byte[] buffer = new byte[1024];
int len = -1;
while((len = inputStream.read(buffer))!= -1){
String text = new String(buffer, 0, len);
Type tokenType = new TypeToken<Map<String, String>>(){}.getType();
Map<String, String> map = new Gson().fromJson(text, tokenType);
String type = map.get("type");
if ("request".equals(type)) {
String action = map.get("action");
if ("auth".equals(action)) {
String sender = map.get("sender");
String token = map.get("token");
clients.put(sender,client);
}else if ("text".equals(action)) {
// 文字訊息
//String sender = map.get("sender");
String receiver = map.get("receiver");
String content = map.get("content");
Socket s = clients.get(receiver);
//依次回覆訊息
if (s != null) {
OutputStream out = s.getOutputStream();
out.write(content.getBytes());
}
}
}
}
} catch (IOException e) {
e.printStackTrace();
}
}
}).start();
}
} catch (IOException e) {
e.printStackTrace();
}
}
}———————————————————————
(java 架構師全套教程，共760G, 讓你從零到架構師，每月輕鬆拿3萬）
有需求者請進站檢視，非誠勿擾
https://item.taobao.com/item.htm?spm=686.1000925.0.0.4a155084hc8wek&id=55588852620101.高階架構師四十二個階段高
02.Java高階系統培訓架構課程148課時
03.Java高階網際網路架構師課程
04.Java網際網路架構Netty、Nio、Mina等-視訊教程
05.Java高階架構設計2016整理-視訊教程
06.架構師基礎、高階片
07.Java架構師必修linux運維繫列課程
08.Java高階系統培訓架構課程116課時
（送：hadoop系列教程，java設計模式與資料結構， Spring Cloud微服務， SpringBoot入門）
——————————————————————–