1. 如何用java实现服务器确认后客户端才能发送下一条信息。
Server代码
packagecom.javacodegeeks.android.androidsocketserver;
importjava.io.BufferedReader;
importjava.io.IOException;
importjava.io.InputStreamReader;
importjava.net.ServerSocket;
importjava.net.Socket;
importandroid.app.Activity;
importandroid.os.Bundle;
importandroid.os.Handler;
importandroid.util.Log;
importandroid.widget.TextView;
{
;
;
privateThreadserverThread=null;
privateTextViewtext;
=6000;
@Override
publicvoidonCreate(BundlesavedInstanceState)
{
super.onCreate(savedInstanceState);
setContentView(R.layout.main);
text=(TextView)findViewById(R.id.text2);
updateConversationHandler=newHandler();
this.serverThread=newThread(newServerThread());
this.serverThread.start();
}
@Override
protectedvoidonStop()
{
super.onStop();
try
{
serverSocket.close();
}
catch(IOExceptione)
{
e.printStackTrace();
}
}
{
publicvoidrun()
{
Socketsocket=null;
try
{
serverSocket=newServerSocket(SERVERPORT);
}
catch(IOExceptione)
{
e.printStackTrace();
}
while(!Thread.currentThread().isInterrupted())
{
try
{
socket=serverSocket.accept();//TODO
CommunicationThreadcommThread=newCommunicationThread(socket);
newThread(commThread).start();
}
catch(IOExceptione)
{
Log.i("liu","socket.accept()失败");
e.printStackTrace();
}
}
}
}
{
privateSocketclientSocket;
privateBufferedReaderinput;
publicCommunicationThread(SocketclientSocket)
{
this.clientSocket=clientSocket;
Log.i("liu","获取到了client的Socket");
try
{
this.input=newBufferedReader(newInputStreamReader(this.clientSocket.getInputStream()));//TODO
}
catch(IOExceptione)
{
Log.i("liu","input获取失败");
e.printStackTrace();
}
}
publicvoidrun()
{
while(!Thread.currentThread().isInterrupted())
{
try
{
Stringread=input.readLine();//TODO
Log.i("liu",read);
updateConversationHandler.post(newupdateUIThread(read));
}
catch(IOExceptione)
{
Log.i("liu","input读取失败");
e.printStackTrace();
}
}
}
}
{
privateStringmsg;
publicupdateUIThread(Stringstr)
{
this.msg=str;
}
@Override
publicvoidrun()
{
text.setText(text.getText().toString()+"ClientSays:"+msg+" ");
}
}
}
2. Client代码：
packagecom.javacodegeeks.android.androidsocketclient;
importjava.io.BufferedWriter;
importjava.io.IOException;
importjava.io.OutputStreamWriter;
importjava.io.PrintWriter;
importjava.net.InetAddress;
importjava.net.Socket;
importjava.net.UnknownHostException;
importandroid.app.Activity;
importandroid.os.Bundle;
importandroid.util.Log;
importandroid.view.View;
importandroid.widget.EditText;
{
privateSocketsocket;
=4000;
_IP="10.0.2.2";
@Override
publicvoidonCreate(BundlesavedInstanceState)
{
super.onCreate(savedInstanceState);
setContentView(R.layout.main);
newThread(newClientThread()).start();
}
publicvoidonClick(Viewview)
{
try
{
EditTextet=(EditText)findViewById(R.id.EditText01);
Stringstr=et.getText().toString();
Log.i("liu","点击按钮");
PrintWriterout=newPrintWriter(newBufferedWriter(newOutputStreamWriter(socket.getOutputStream())),true);//TODO
out.println(str);
}
catch(Exceptione)
{
Log.i("liu","write失败");
e.printStackTrace();
}
}
{
@Override
publicvoidrun()
{
try
{
InetAddressserverAddr=InetAddress.getByName(SERVER_IP);
socket=newSocket(serverAddr,SERVERPORT);
}
catch(UnknownHostExceptione1)
{
e1.printStackTrace();
}
catch(IOExceptione1)
{
e1.printStackTrace();
}
}
}
}
2. Android上实现TCP服务端
之前已经讲过了tcp客户端的实现了，大家有兴趣的话，可以参看文章
Android上实现TCP客户端
那么，今天我们就来讲讲tcp之服务端的封装吧。我已经将tcp服务端封装成了一个类—TcpServer，下面就来讲讲它的使用吧。
今天涉及内容：
先来波效果图
在 tcp服务端 建立 ServerSocket 的时候，我们通常是这样的：
其实以上方法调用的是
其中涉及到的参数：
鉴于tcp服务端 ServerSocket 一般运行在 "本机" 上，则快速初始化 ServerSocket 运用上面的方法：
意思是建立的ServerSocket IP地址为本机，可容纳socket个数为 50 。
在理解了 ServerSocket 初始化问题后，让我们来看看封装类TcpServer的几个主要方法：
TcpServer 主要是在 java 上运行，所以就让我们在 Androidstudio 上模拟下在 Java 中运行tcp服务端的场景：
这里涉及到的两个类 SocketConfig 和 SocketHelper 和之前的一样，大家可以参考文章 Android上实现TCP客户端 中与之相关的介绍，这里就不赘述了。
tcp服务端主要容易出现以下两个问题：
对于第一个问题，这里需要强调的是 TcpServer 的接收方法 receiveMessage(String charsetName) 是以 (result = bufferedReader.readLine()) != null 做判断读取 stream 的，所以客户端向 TcpServer 发送消息时，需要在结尾加上\n,这样 TcpServer 的receiveMessage(String charsetName)方法才能将传过来的数据接收完整。
对于第二个问题，则需要客户端与服务端设置相同的字符集以保证数据不乱码。
封装类 TcpServer 源码如下: