一对一Socket简单聊天的实现

　　今天终于调试通了Socket一对一的聊天，每次发送连接请求后，将用户名发送到Socket中去，然后将用户名和新建的socket存到map中，然后根据用户名来确定接收方是谁，以实现一对一的聊天功能。

　　上图是我看博客的时候截下来的图，这就是大概思路了。具体今天的实现，我写了一个界面，上边有服务器ip地址，用来连接服务器。

　　以及发送方，接收方，消息内容。发送的时候，将这三条数据连接起来，末尾加"\n"，以便readLine()函数读取内容。然后发送消息。三个按钮的单击事件如下所示，界面在后边会贴出来。

     //*****************************主要工作********************************

     Socket socket = null;

     BufferedReader br = null;

     BufferedWriter bw = null;

     protected void connect() {

         AsyncTask<Void, String, Void> reader = new AsyncTask<Void, String, Void>(){

             @Override

             protected Void doInBackground(Void... arg0) {

                 try {

                     socket = new Socket(editIp.getText().toString(), 12345);

                     br = new BufferedReader(new InputStreamReader(socket.getInputStream()));

                     bw = new BufferedWriter(new OutputStreamWriter(socket.getOutputStream()));

                     publishProgress("@success");

                 } catch (UnknownHostException e1) {

                     Toast.makeText(MainActivity.this, "无法建立连接", Toast.LENGTH_SHORT).show();

                 } catch (IOException e1) {

                     Toast.makeText(MainActivity.this, "无法建立连接", Toast.LENGTH_SHORT).show();

                 }

                 try {

                     String line = "";

                     while((line = br.readLine()) != null){

                         publishProgress(line);

                     }

                 } catch (IOException e) {

                     // TODO Auto-generated catch block

                     e.printStackTrace();

                 }

                 return null;

             }

             @Override

             protected void onProgressUpdate(String... values) {

                 // TODO Auto-generated method stub

                 if (values[0].equals("@success")) {

                     Toast.makeText(MainActivity.this, "连接成功", Toast.LENGTH_SHORT).show();

                 }

                 tvNeirong.append("对方说:"+values[0]+"\n");

                 super.onProgressUpdate(values);

             }

         };

         reader.execute();

     }

     protected void login() {

         // TODO Auto-generated method stub

         try {

             bw.write(editUsername.getText().toString()+"\n");

             bw.flush();

         } catch (IOException e) {

             // TODO Auto-generated catch block

             e.printStackTrace();

         }

     }

     protected void send() {

         // TODO Auto-generated method stub

         try {

             tvNeirong.append("我说:"+editContent.getText().toString()+"\n");

             //将消息内容连接为一个字符串，格式为FromID \n Content \n ToID \n

             //因为将来读取时候用的是readLine()函数，所以必须加\n

             String str = editUsername.getText().toString()+"\n"

                     +editContent.getText().toString()+"\n"

                     +editToID.getText().toString()+"\n";

             bw.write(str);

             bw.flush();

             editContent.setText("");

         } catch (IOException e) {

             // TODO Auto-generated catch block

             e.printStackTrace();

         }

     }

　　然后我开了三个安卓模拟器，两个Eclipse，电脑内存飙到了百分之八十多，测试完成后赶紧关了，一顿卡，大概如下所示，三个用户为10001,10002,10003，我让10001->10002,10002->10003,10003->10001，这样互相发送消息，实现的效果如下图所示：

　　然后贴出我的ServerSocket中的logcat内容，这些消息是封装成了Json字符串来发送的。

　　消息的格式为FromID+"\n"+Content+"\n"+ToID+"\n"，这样就组成了一个完整的字符串，readLine()函数遇到"\n"就会停止，每次将对应的变量解析出来，然后服务端再去发送消息就可以了。

　　好了，有什么问题还会来这里补充，(仅供自己学习参考0.0)

巴特西

一对一Socket简单聊天的实现

最新文章

热门文章