android实现简单的聊天室

先说一下流程。首先是建立一个java工程，并创建两个java类，一个用于接收到客户端的连接，并把连接添加list中，第二类实现线程runnable接口，专门用来接收发送客户发送的信息。其次，建立android工程，并创建两个类，一个用于显示聊天界面，另一个负责接收服务器端返回的信息。这个例子肯定会有考虑不周的地方但是只是为了学习android中网络相关api的使用，所以请大家谨慎拍砖。

首先还是android的内容

[html] view plain copy print ?

<RelativeLayoutxmlns:android="http://schemas.android.com/apk/res/android"
xmlns:tools="http://schemas.android.com/tools"
android:layout_width="match_parent"
android:layout_height="match_parent">
<EditText
android:id="@+id/et_show"
android:layout_width="fill_parent"
android:layout_height="wrap_content"
android:lines="5"
android:hint="所有聊天信息"
android:gravity="center"
/>
<EditText
android:id="@+id/et_input"
android:layout_below="@+id/et_show"
android:layout_width="fill_parent"
android:layout_height="wrap_content"
android:hint="输入聊天信息"
android:gravity="center"
/>
<Button
android:id="@+id/bt_send"
android:layout_below="@+id/et_input"
android:layout_width="fill_parent"
android:layout_height="wrap_content"
android:text="发送信息"
/>
</RelativeLayout>

接着是MainAvitvity.java

[java] view plain copy print ?

publicclassMainActivityextendsActivity{
privateEditTextet_show,et_input;
privateButtonbt_send;
privateOutputStreamos;
privateHandlerhandler;
@Override
protectedvoidonCreate(BundlesavedInstanceState){
super.onCreate(savedInstanceState);
setContentView(R.layout.activity_main);
et_input=(EditText)this.findViewById(R.id.et_input);
et_show=(EditText)this.findViewById(R.id.et_show);
bt_send=(Button)this.findViewById(R.id.bt_send);
try{
//定义客户连接的socket
Socketsocket=newSocket("本机IP",30000);
//启动客户端监听线程
newThread(newClinetThread(socket,handler)).start();
os=socket.getOutputStream();
}catch(UnknownHostExceptione){
e.printStackTrace();
}catch(IOExceptione){
e.printStackTrace();
}
bt_send.setOnClickListener(newOnClickListener(){
@Override
publicvoidonClick(Viewv){
try{
//得到输入框中的内容，写入到输入流中
os.write((et_input.getText().toString()+"\r\n").getBytes("utf-8"));
et_input.setText("");
}catch(UnsupportedEncodingExceptione){
//TODOAuto-generatedcatchblock
e.printStackTrace();
}catch(IOExceptione){
//TODOAuto-generatedcatchblock
e.printStackTrace();
}
}
});
handler=newHandler(){
@Override
publicvoidhandleMessage(Messagemsg){
super.handleMessage(msg);
if(msg.what==1){
//得到服务器返回的信息
et_show.append("\n"+msg.obj.toString());
}
}
};
}
}

第三是客户端的线程类

[java] view plain copy print ?

publicclassClinetThreadimplementsRunnable{
Socketsocket=null;
Handlerhandler=null;
BufferedReaderbr=null;
publicClinetThread(Socketsocket,Handlerhandler){
this.socket=socket;
this.handler=handler;
try{
br=newBufferedReader(newInputStreamReader(socket.getInputStream()));
}catch(IOExceptione){
e.printStackTrace();
}
}
@Override
publicvoidrun(){
Stringcontent=null;
try{
while((content=br.readLine())!=null){
Messagemsg=newMessage();
msg.what=1;
msg.obj=content;
handler.sendMessage(msg);
}
}catch(IOExceptione){
e.printStackTrace();
}
}
}

接下来是Java工程中的主类

[java] view plain copy print ?

/**
*创建ServerSocket监听的主类
*该类只负责接收客户端的socket连接请求，每当客户端
*连接到该serversocket之后，程序将对应socket加入到list
*并为该socket开一挑单独的线程，负责socket的所有通信任务
*@authorAdministrator
*
*/
publicclassSimpleServer{
//定义保存所有Socket的ArrayList
publicstaticArrayList<Socket>socketList=newArrayList<Socket>();
publicstaticvoidmain(String[]args){
try{
ServerSocketss=newServerSocket(30000);
while(true){
Sockets=ss.accept();
socketList.add(s);
newThread(newServerThead(s)).start();
}
}catch(IOExceptione){
e.printStackTrace();
}
}
}

其次java工程中的线程类

[java] view plain copy print ?

/**
*负责每个线程通信的类
*该类不断读取客户端数据，使用自定义的readFromClient()方法读取
*客户端数据，如果出现异常表明该socket对应的客户端socket出现了问题
*程序将该socket从list中移除。
*当服务器线程读取到了客户端数据后，遍历list集合，并将数据发送到每个
*socket中
*@authorAdministrator
*
*/
publicclassServerTheadimplementsRunnable{
//定义当前线程处理的socket
Sockets=null;
//该线程所处理的socket对应的输入流
BufferedReaderbr=null;
publicServerThead(Sockets)throwsIOException{
this.s=s;
br=newBufferedReader(newInputStreamReader(s.getInputStream()));
}
@Override
publicvoidrun(){
Stringconntent=null;
while((conntent=readFromClient())!=null){
//遍历socket中的每一个socket
for(Sockets:SimpleServer.socketList){
try{
OutputStreamos=s.getOutputStream();
os.write((conntent+"\n").getBytes("utf-8"));
}catch(IOExceptione){
e.printStackTrace();
}
}
}
}
privateStringreadFromClient(){
try{
returnbr.readLine();
}catch(IOExceptione){
e.printStackTrace();
SimpleServer.socketList.remove(s);
}
returnnull;
}
}
转载请标明出处：雅荷湾

更多相关文章

随机推荐