Android实现C/S聊天室
Java中能接受其他通信实体链接请求的类是ServerSocket，ServerSocket对象用于监听来自客户端的Socket链接，如果没有链接，它将一直等待。如果接收到一个客户端Socket的连接请求，ServerSocket的accept()方法将返回一个与客户端Socket对应的Socket（每个TCP连接有两个Socket），否则该方法将一直阻塞，线程也被阻塞。
服务端思路：服务端应该包含多个线程，每个Socket对应一个线程，这个线程负责读取该Socket对应输入流的数据（从客户端发送过来的数据），并将读到的数据向每个Socket输出流发送一次（将一个客户端发送过来的数据“广播”给其他客户端）。
服务端代码：
//服务端主类
publicclassMyServer
{
publicstaticListsocketList=Collections.synchronizedList(newArrayList());
publicstaticvoidmain(String[]args)throwsIOException
{
ServerSocketss=newServerSocket(30000);
while(true)
{
//此行代码会阻塞，将一直等待别人的连接
Sockets=ss.accept();
socketList.add(s);
//每当客户端连接后启动一个ServerThread线程为该客户端服务
newThread(newServerThread(s)).start();
}
}
}
publicclassServerThreadimplementsRunnable
{
//定义当前线程所处理的Socket
Sockets=null;
//该线程所处理的Socket对应的输入流
BufferedReaderbr=null;
publicServerThread(Sockets)throwsIOException
{
this.s=s;
//初始化该Socket对应的输入流
br=newBufferedReader(newInputStreamReader(s.getInputStream()));
}
@Override
publicvoidrun()
{
try
{
Stringcontent=null;
//采用循环不断地从Socket中读取客户端发送来的数据
while((content=readFromClient())!=null)
{
//遍历socketList中的每个Socket
//将读到的内容向每个Socket发送一次
for(Sockets:MyServer.socketList)
{
PrintStreamps=newPrintStream(s.getOutputStream());
ps.println(content);
}
}
}
catch(IOExceptione)
{
e.printStackTrace();
}
}
//定义读取客户端数据的方法
privateStringreadFromClient()
{
try
{
returnbr.readLine();
}
//如果捕获到异常，则表明该Socket对应的客户端已经关闭
catch(IOExceptione)
{
//删除该Socket
MyServer.socketList.remove(s);
}
returnnull;
}
}
客户端思路：将用户输入的数据写入Socket对应的输入流中；开启一个子线程读取Socket对应输入流中的数据（从服务端发送过来的数据），并通过Handler将读取的数据发送到主线程来更新UI。
//用户界面Activity
publicclassMainActivityextendsActivity
{
privateEditTextmReceiverMsg;
privateButtonmSendBtn;
privateEditTextmSendMsg;
Handlerhandler=newHandler()
{
@Override
publicvoidhandleMessage(Messagemsg)
{
Log.d("mainActivity","okk");
mReceiverMsg.append(msg.obj.toString());
}
};
privateSockets;
@Override
protectedvoidonCreate(BundlesavedInstanceState)
{
super.onCreate(savedInstanceState);
setContentView(R.layout.main_activity);
initView();
initSocket();
mSendBtn.setOnClickListener(newView.OnClickListener()
{
@Override
publicvoidonClick(Viewview)
{
sendData();
}
});
}
privatevoidinitSocket()
{
newThread()
{
@Override
publicvoidrun()
{
try
{
s=newSocket("192.168.1.101",30000);
newThread(newClientThread(s,handler)).start();
}
catch(IOExceptione)
{
e.printStackTrace();
}
}
}.start();
}
privatevoidinitView()
{
mReceiverMsg=(EditText)findViewById(R.id.receiver_message);
mSendMsg=(EditText)findViewById(R.id.send_message);
mSendBtn=(Button)findViewById(R.id.send_button);
}
privatevoidsendData()
{
try
{
//获取该Socket对应的输出流
PrintStreamps=newPrintStream(s.getOutputStream());
if(TextUtils.isEmpty(mSendMsg.getText()))
{
Toast.makeText(this,"请输入信息",Toast.LENGTH_LONG).show();
return;
}
ps.println(mSendMsg.getText().toString());
}
catch(IOExceptione)
{
e.printStackTrace();
}
}
}
publicclassClientThreadimplementsRunnable
{
//该线程负责处理的Socket
privateSocketss;
//该线程所处理的Socket对应的输入流
BufferedReaderbr=null;
Handlerhandler;
publicClientThread(Sockets,Handlerhandler)throwsIOException
{
this.ss=s;
this.handler=handler;
br=newBufferedReader(newInputStreamReader(ss.getInputStream()));
}
@Override
publicvoidrun()
{
try
{
Stringcontent=null;
while((content=br.readLine())!=null)
{
Messagemsg=newMessage();
msg.obj=content;
handler.sendMessage(msg);
}
}
catch(IOExceptione)
{
e.printStackTrace();
}
}
}
先运行上面程序中的MyServer类，该类运行只是作为服务端。再启动多个模拟器，运行安装客户端的程序作为多个客户端，然后可以再任何一个客户端通过Edit输入一些内容，点击发送就可以在任何一个客户端看到刚刚输入的内容。
以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持毛票票。