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);
}
-
注意在安卓权限中加入网络权限
<uses-permission android:name="android.permission.INTERNET"/> -
Client端截图
2016-03-24_223256.png
