Android(安卓)socket通信app Client端
16lz
2021-01-26
MainActivity.java
package com.houxy.chat;import android.app.Activity;import android.os.Bundle;import android.os.Handler;import android.os.Looper;import android.view.View;import android.widget.Button;import android.widget.EditText;import android.widget.TextView;import android.widget.Toast;public class MainActivity extends Activity implements View.OnClickListener{ private EditText editIP; private EditText editPort; private EditText editMsg; private Button btnLink; private Button btnSend; private TextView textReceive; private Handler mHandler = new Handler(Looper.getMainLooper()); private TcpClient tcpClient = new TcpClient() { @Override public void onConnect() { refreshUI(true); } @Override public void onConnectBreak() { refreshUI(false); } @Override public void onReceive(final String s) { mHandler.post(new Runnable() { @Override public void run() { textReceive.append("server:" + s + "\n\n"); } }); } @Override public void onConnectFalied() { mHandler.post(new Runnable() { @Override public void run() { Toast.makeText(getApplicationContext(), "连接失败", Toast.LENGTH_LONG); } }); } @Override public void onSendSuccess(final String s) { mHandler.post(new Runnable() { @Override public void run() { textReceive.append("我:" + s + "\n\n"); } }); } }; private void refreshUI(final boolean isConnected) { mHandler.post(new Runnable() { @Override public void run() { editIP.setEnabled(!isConnected); editPort.setEnabled(!isConnected); btnLink.setText(isConnected ? "断开" : "连接"); btnSend.setBackgroundResource(isConnected ? R.drawable.send_button : R.drawable.send_button_disabled ); } }); } @Override protected void onCreate(Bundle savedInstanceState) { super.onCreate(savedInstanceState); initView(); refreshUI(false); } @Override public void onClick(View v) { switch (v.getId()){ case R.id.btn_Link: if(tcpClient.isConnected()){ tcpClient.disConnected(); }else { String IP = editIP.getText().toString().trim(); String strPort = editPort.getText().toString(); int port = Integer.parseInt(strPort); tcpClient.connect(IP, port); } break; case R.id.btn_sendMsg: String msg = editMsg.getText().toString(); editMsg.setText(""); tcpClient.getTransceiver().sendMSG(msg); break; default: break; } } @Override protected void onStop() { tcpClient.disConnected(); super.onStop(); } private void initView() { setContentView(R.layout.activity_main); editIP = (EditText)findViewById(R.id.ed_ip); editPort = (EditText)findViewById(R.id.ed_port); editMsg = (EditText)findViewById(R.id.edit_msg); btnLink = (Button)findViewById(R.id.btn_Link); btnSend = (Button)findViewById(R.id.btn_sendMsg); textReceive = (TextView)findViewById(R.id.tx_receive); // listView = (ListView)findViewById(R.id.listView); btnSend.setOnClickListener(this); btnLink.setOnClickListener(this); }}TcpClient.java
- TcpClient 是Tcp Socket客户端的程序,主要是实现socket的连接,并利用SocketTransceiver进行数据的收发工作
- 这里对几个抽象函数特别介绍一下
public abstract void onConnect(); //当socket成功连接的时候回调此函数刷新UI界面public abstract void onConnectBreak(); //当连接意外断开的时候回调此函数public abstract void onReceive(String s); //当收到服务器端发送回来的数据时,回调此函数,显示聊天数据在UI界面public abstract void onConnectFalied(); //开始连接未完成,抛出异常时回调此函数public abstract void onSendSuccess(String s); //当socket 服务器端接收到数据后将发送的数据显示在客户端界面package com.houxy.chat;import android.util.Log;import java.io.IOException;import java.net.Socket;/** * Created by asus on 2016/3/23. */public abstract class TcpClient implements Runnable{ private String IP; private int port; boolean connect = false; private SocketTransceiver transceiver; private Socket socket; public void connect(String IP, int port){ this.IP = IP; this.port = port; new Thread(this).start(); } @Override public void run() { try { transceiver = new SocketTransceiver() { @Override public void onReceive(String s) { TcpClient.this.onReceive(s); } @Override public void onConnectBreak() { TcpClient.this.onConnectBreak(); } @Override public void onSendSuccess(String s) { TcpClient.this.onSendSuccess(s); } }; socket = new Socket(IP, port); connect = true; Log.d("connect", String.valueOf(connect)); this.onConnect(); transceiver.start(socket); } catch (IOException e) { this.onConnectFalied(); e.printStackTrace(); } } protected boolean isConnected(){ return connect; } public void disConnected(){ connect = false; if(transceiver!=null){ transceiver.stop(); transceiver=null; } } public SocketTransceiver getTransceiver(){ return transceiver; } public abstract void onConnect(); public abstract void onConnectBreak(); public abstract void onReceive(String s); public abstract void onConnectFalied(); public abstract void onSendSuccess(String s);}SocketTransceiver.java
- 此类主要是进行数据的收发
- 这里的几个抽象方法同上
package com.houxy.chat;import java.io.DataInput;import java.io.DataInputStream;import java.io.DataOutputStream;import java.io.IOException;import java.io.InputStream;import java.io.OutputStream;import java.io.OutputStreamWriter;import java.net.Socket;/** * Created by asus on 2016/3/23. */public abstract class SocketTransceiver implements Runnable{ private Socket socket; private DataInputStream dataInputStream; private DataOutputStream dataOutputStream; private InputStream inputStream; private OutputStream outputStream; private boolean runFlag = false; public void start(Socket socket){ this.socket = socket; runFlag = true; new Thread(this).start(); } public void stop(){ runFlag = false; try { socket.shutdownInput(); inputStream.close(); } catch (IOException e) { e.printStackTrace(); } } @Override public void run() { try { inputStream = socket.getInputStream(); outputStream = socket.getOutputStream(); } catch (IOException e) { runFlag = false; e.printStackTrace(); } while (runFlag){ //线程死循环 不停的从服务器端读回数据,并通过onReceiver()方法回传显示到UI dataInputStream = new DataInputStream(inputStream); try { String s = dataInputStream.readUTF(); this.onReceive(s); } catch (IOException e) { runFlag = false; e.printStackTrace(); } } //断开连接 try { inputStream.close(); outputStream.close(); socket.close(); dataInputStream.close(); if (dataOutputStream != null) dataOutputStream.close(); } catch (IOException e) { e.printStackTrace(); } this.onConnectBreak();//连接被动断开 } public void sendMSG(String s){ if( outputStream != null){ dataOutputStream = new DataOutputStream(outputStream); try { dataOutputStream.writeUTF(s); dataOutputStream.flush(); this.onSendSuccess(s); } catch (IOException e) { onConnectBreak(); runFlag = false; e.printStackTrace(); } } } public abstract void onReceive(String s); public abstract void onConnectBreak(); public abstract void onSendSuccess(String s);}-
注意在安卓权限中加入网络权限
-
Client端截图
更多相关文章
- 一句话锁定MySQL数据占用元凶
- HttpURLconnection上传数据
- Android(安卓)封装的数据库管理操作类
- Android(安卓)直接通过JNI访问驱动
- adb使用wifi无线连接调试Android设备
- android 蓝牙发送数据
- Android(安卓)-Okhttp框架 工具类
- android 混淆代码gson数据nullpointerexception
- RF Analyzer for Android(安卓)安卓平台连接HackRF的App