以C#编写的Socket服务器的Android手机聊天室Demo

长平狐 发布于 2012/06/11 11:54
阅读 4K+
收藏 1

 

   内容摘要

   1.程序架构

   2.通信协议

   3.服务器源代码

   4.客户端源代码

   5.运行效果

 

  一、程序架构

  在开发一个聊天室程序时,我们可以使用Socket、Remoting、WCF这些具有双向通信的协议或框架。而现在,我正要实现一个C#语言作为服务器端、Android作为客户端的聊天室。由于服务器端和客户端不是同一语言(C#和java),所有我选择了Socket作为通信协议。

  图1.1所示,我们可以看出:android手机客户端A向服务器端发送消息,服务器端收到消息后,又把消息推送到android手机客户端B。

 图1.1

 

  二、通信协议

我们知道,在C#语言中使用Socket技术需要“四部曲”,即“Bind”,“Listen”,“Accept”,“Receive”。然而Socket编程不像WCF那样面向对象。而且对应每个请求都用同一种方式处理。作为习惯面向对象编程的我来说,编写一个传统的Socket程序很不爽。绞尽脑汁,我们将数据传输的格式改为json(JavaScript Object Notation 是一种轻量级的数据交换格式),面对对象的问题就解决了。

   假设程序的服务契约有两个方法:“登陆”和“发送消息”。调用登陆的方法,就传送方法名(Method Name)为“Logon”的json数据;调用发送消息的方法,就传送方法名为“Send”的json数据。返回的数据中也使用json格式,这样在android客户端中也能知道是哪个方法的返回值了。

 

  三、服务器源代码

 首先需要编写一个处理客户端消息的接口:IResponseManager。

 

     public   interface  IResponseManager
    {
        
void  Write(Socket sender, IList < Socket >  cliens, IDictionary < string object >  param);
    }

 

 

其次,我们知道,换了是WCF编程的话,就需要在服务契约中写两个方法:“登陆”和“发送消息”。由于这里是Socket编程,我们实现之前写的IResponseManager接口,一个实现作为“登陆”的方法,另一个实现作为“发送消息”的方法。

 

public   class  LogonResponseManager : IResponseManager
    {
        
public   void  Write(System.Net.Sockets.Socket sender, IList < System.Net.Sockets.Socket >  cliens, IDictionary < string object >  param)
        {
            Console.WriteLine(
" 客户端({0})登陆 " , sender.Handle);
            var response 
=   new  SocketResponse
            {
                Method 
=   " Logon " ,
                DateTime 
=  DateTime.Now.ToString( " yyyy-MM-dd HH🇲🇲ss " ),
                Result 
=   new  { UserName  =  param[ " UserName " ].ToString() }
            };

            JavaScriptSerializer jss 
=   new  JavaScriptSerializer();
            
string  context  =  jss.Serialize(response);
            Console.WriteLine(
" 登陆发送的数据为:{0} " , context);
            sender.Send(Encoding.UTF8.GetBytes(context 
+   " \n " ));
        }
    }

 

 

public   class  SendResponseManager : IResponseManager
    {
        
public   void  Write(System.Net.Sockets.Socket sender, IList < System.Net.Sockets.Socket >  cliens, IDictionary < string object >  param)
        {
            Console.WriteLine(
" 客户端({0})发送消息 " , sender.Handle);
            var msgList 
=  param[ " Message " as  IEnumerable < object > ;
            
if  (msgList  ==   null )
            {
                
return ;
            }

            var response 
=   new  SocketResponse
            {
                Method 
=   " Send " ,
                DateTime 
=  DateTime.Now.ToString( " yyyy-MM-dd HH🇲🇲ss " ),
                Result 
=   new
                { 
                    UserName 
=  param[ " UserName " ].ToString(),
                    Message 
=  msgList.Select(s  =>  s.ToString()).ToArray() 
                }
            };

            JavaScriptSerializer jss 
=   new  JavaScriptSerializer();
            
string  context  =  jss.Serialize(response);
            Console.WriteLine(
" 消息发送的数据为:{0} " , context);

            Parallel.ForEach(cliens, (item) 
=>
            {
                
try
                {
                    item.Send(Encoding.UTF8.GetBytes(context 
+   " \n " ));
                }
                
catch  { };
            });
        }
    }

 

最后在Socket程序中使用反射加“策略模式”调用这两个接口实现类。

 

            var typeName  =   " SocketServer. "   +  request.Method  +   " ResponseManager, SocketServer " ;
            Console.WriteLine(
" 反射类名为: "   +  typeName);

            Type type 
=  Type.GetType(typeName);
            
if  (type  ==   null )
            {
                
return ;
            }

            var manager 
=  Activator.CreateInstance(type)  as  IResponseManager;
            manager.Write(sender, 
this .socketClientSesson.Select(s  =>  s.Key).ToList(),
                request.Param 
as  IDictionary < string object > );

 

完整的Socket服务器代码如下:

 

public   class  SocketHost
    {
        
private  IDictionary < Socket,  byte [] >  socketClientSesson  =   new  Dictionary < Socket,  byte [] > ();

        
public   int  Port {  get set ; }

        
public   void  Start()
        {
            var socketThread 
=   new  Thread(()  =>
            {
                Socket socket 
=   new  Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
                IPEndPoint iep 
=   new  IPEndPoint(IPAddress.Any,  this .Port);

                
// 绑定到通道上
                socket.Bind(iep);

                
// 侦听
                socket.Listen( 6 );

                
// 通过异步来处理
                socket.BeginAccept( new  AsyncCallback(Accept), socket);

            });

            socketThread.Start();

            Console.WriteLine(
" 服务器已启动 " );
        }

        
private   void  Accept(IAsyncResult ia)
        {
            Socket socket 
=  ia.AsyncState  as  Socket;
            var client 
=  socket.EndAccept(ia);

            socket.BeginAccept(
new  AsyncCallback(Accept), socket);

            
byte [] buf  =   new   byte [ 1024 ];
            
this .socketClientSesson.Add(client, buf);

            
try
            {
                client.BeginReceive(buf, 
0 , buf.Length, SocketFlags.None,  new  AsyncCallback(Receive), client);
                
string  sessionId  =  client.Handle.ToString();
                Console.WriteLine(
" 客户端({0})已连接 " , sessionId);
            }
            
catch  (Exception ex)
            {
                Console.WriteLine(
" 监听请求时出错:\r\n "   +  ex.ToString());
            }
        }

        
private   void  Receive(IAsyncResult ia)
        {
            var client 
=  ia.AsyncState  as  Socket;

            
if  (client  ==   null   ||   ! this .socketClientSesson.ContainsKey(client))
            {
                
return ;
            }

            
int  count  =  client.EndReceive(ia);

            
byte [] buf  =   this .socketClientSesson[client];

            
if  (count  >   0 )
            {
                
try
                {
                    client.BeginReceive(buf, 
0 , buf.Length, SocketFlags.None,  new  AsyncCallback(Receive), client);
                    
string  context  =  Encoding.UTF8.GetString(buf,  0 , count);
                    Console.WriteLine(
" 接收的数据为: " , context);

                    
this .Response(client, context);
                }
                
catch  (Exception ex)
                {
                    Console.WriteLine(
" 接收的数据出错:\r\n{0} " , ex.ToString());
                }
            }
            
else
            {
                
try
                {
                    
string  sessionId  =  client.Handle.ToString();
                    client.Disconnect(
true );
                    
this .socketClientSesson.Remove(client);
                    Console.WriteLine(
" 客户端({0})已断开 " , sessionId);
                }
                
catch  (Exception ex)
                {
                    Console.WriteLine(
" 客户端已断开出错 "   +  ex.ToString());
                }
            }
        }

        
private   void  Response(Socket sender,  string  context)
        {
            SocketRequest request 
=   null ;
            JavaScriptSerializer jss 
=   new  JavaScriptSerializer();
            request 
=  jss.Deserialize(context,  typeof (SocketRequest))  as  SocketRequest;

            
if  (request  ==   null )
            {
                
return ;
            }

            var typeName 
=   " SocketServer. "   +  request.Method  +   " ResponseManager, SocketServer " ;
            Console.WriteLine(
" 反射类名为: "   +  typeName);

            Type type 
=  Type.GetType(typeName);
            
if  (type  ==   null )
            {
                
return ;
            }

            var manager 
=  Activator.CreateInstance(type)  as  IResponseManager;
            manager.Write(sender, 
this .socketClientSesson.Select(s  =>  s.Key).ToList(),
                request.Param 
as  IDictionary < string object > );
        }
    }

 

 

最后,json数据传输的实体对象为:

 

   [Serializable]
    
public   class  SocketRequest
    {
        
public   string  Method {  get set ; }

        
public   string  DateTime {  get set ; }

        
public   object  Param {  get set ; }
    }

 

 

    [Serializable]
    
public   class  SocketResponse
    {
        
public   string  Method {  get set ; }

        
public   string  DateTime {  get set ; }

        
public   object  Result {  get set ; }
    }

 

 四、客户端源代码

1.布局文件

logon.xml:

 

<? xml version="1.0" encoding="utf-8" ?>
< LinearLayout  xmlns:android ="http://schemas.android.com/apk/res/android"
    android:orientation
="vertical"  android:layout_width ="fill_parent"
    android:layout_height
="fill_parent"  android:background ="@drawable/background" >

    
< LinearLayout  android:orientation ="vertical"
        android:layout_width
="fill_parent"  android:layout_height ="60dip"
        android:background
="@drawable/logon"   />

    
< LinearLayout  android:orientation ="vertical"
        android:layout_width
="fill_parent"  android:layout_height ="fill_parent"
        android:paddingLeft
="10dp"  android:paddingRight ="10dp" >

        
< View  android:layout_width ="fill_parent"  android:layout_height ="20dip"   />

        
< TextView  android:id ="@+id/feedback_title"  android:textColor ="#FFFFFF"
            android:layout_width
="fill_parent"  android:layout_height ="wrap_content"
            android:text
="用户名:"   />
        
< EditText  android:id ="@+id/edtUserName"  android:layout_width ="fill_parent"
            android:layout_height
="wrap_content"   />

        
< View  android:layout_width ="fill_parent"  android:layout_height ="2dip"
            android:background
="#FF909090"   />

        
< TextView  android:layout_width ="fill_parent"
            android:textColor
="#FFFFFF"  android:layout_height ="wrap_content"
            android:text
="IP地址:"   />
        
< EditText  android:id ="@+id/edtIp"  android:layout_width ="fill_parent"
            android:layout_height
="wrap_content"  android:digits ="1234567890."  
            android:text
="192.168.1.101" />

        
< View  android:layout_width ="fill_parent"  android:layout_height ="2dip"
            android:background
="#FF909090"   />

        
< TextView  android:layout_width ="fill_parent"
            android:textColor
="#FFFFFF"  android:layout_height ="wrap_content"
            android:text
="端口号:"   />
        
< EditText  android:id ="@+id/edtPort"  android:layout_width ="fill_parent"
            android:layout_height
="wrap_content"  android:inputType ="number"
            android:numeric
="integer"  android:text ="1234" />

        
< LinearLayout  android:orientation ="horizontal"
            android:layout_width
="fill_parent"  android:layout_height ="wrap_content"
            android:layout_marginTop
="10dp" >
        
</ LinearLayout >
        
< RelativeLayout  android:layout_width ="fill_parent"
            android:layout_height
="fill_parent" >
            
< View  android:id ="@+id/feedback_content"  android:layout_width ="fill_parent"
                android:layout_height
="fill_parent"  android:maxEms ="10"
                android:minEms
="10"  android:gravity ="top"
                android:layout_marginBottom
="50dip"   />
            
< Button  android:id ="@+id/btnLogon"  android:layout_width ="fill_parent"
                android:layout_height
="50dp"  android:text ="登陆"  android:textSize ="19dp"
                android:layout_gravity
="center_horizontal"
                android:layout_alignParentBottom
="true"   />
        
</ RelativeLayout >
    
</ LinearLayout >
</ LinearLayout >

 

main.xml:

<? xml version="1.0" encoding="utf-8" ?>
< LinearLayout  xmlns:android ="http://schemas.android.com/apk/res/android"
    android:orientation
="vertical"  android:layout_width ="fill_parent"
    android:layout_height
="fill_parent"  android:background ="@drawable/background" >

    
< ListView  android:layout_width ="fill_parent"
        android:layout_height
="wrap_content"  android:id ="@+id/ltvMessage" >
    
</ ListView >

    
< RelativeLayout  android:layout_width ="fill_parent"
        android:layout_height
="wrap_content" >

        
< EditText  android:layout_width ="fill_parent"
            android:layout_height
="wrap_content"  android:id ="@+id/edtMessage"
            android:hint
="请输入消息"  android:layout_alignTop ="@+id/btnSend"
            android:layout_toLeftOf
="@+id/btnSend"   />

        
< Button  android:text ="SEND"  android:id ="@+id/btnSend"
            android:layout_height
="wrap_content"  android:layout_width ="wrap_content"
            android:layout_alignParentRight
="true"   />
    
</ RelativeLayout >

</ LinearLayout >

 

listview_item.xml:

 

<? xml version="1.0" encoding="utf-8" ?>
< LinearLayout  xmlns:android ="http://schemas.android.com/apk/res/android"
    android:layout_width
="fill_parent"  android:layout_height ="wrap_content"
    android:orientation
="vertical"  android:paddingBottom ="3dip"
    android:paddingLeft
="10dip" >

    
< TextView  android:layout_height ="wrap_content"
        android:layout_width
="fill_parent"  android:id ="@+id/itmMessage"
        android:textSize
="20dip" >
    
</ TextView >

    
< LinearLayout  android:layout_width ="fill_parent"
        android:orientation
="horizontal"  android:layout_height ="20dip" >
        
< TextView  android:layout_height ="fill_parent"
            android:layout_width
="100dip"  android:id ="@+id/itmUserName"   >
        
</ TextView >

        
< TextView  android:layout_height ="fill_parent"
            android:layout_width
="200dip"  android:id ="@+id/itmTime"   >
        
</ TextView >

    
</ LinearLayout >

</ LinearLayout >

 

SocketClient:

 

package  ld.socket;

import  java.io.BufferedReader;
import  java.io.BufferedWriter;
import  java.io.IOException;
import  java.io.InputStreamReader;
import  java.io.OutputStreamWriter;
import  java.net.Socket;
import  java.net.UnknownHostException;
import  java.text.SimpleDateFormat;
import  java.util.Date;
import  java.util.HashMap;
import  java.util.Map;

import  org.json.JSONArray;
import  org.json.JSONException;
import  org.json.JSONObject;

import  android.os.Handler;
import  android.os.Message;
import  android.util.Log;

public   class  SocketClient {

    
private   static  Socket client;

    
private   static  SocketClient instance  =   null ;

    
public   static  SocketClient getInstance() {
        
if  (instance  ==   null ) {

            
synchronized  (ChartInfo. class ) {
                
if  (instance  ==   null ) {
                    
try  {
                        ChartInfo chartInfo 
=  ChartInfo.getInstance();
                        client 
=   new  Socket(chartInfo.getIp(), chartInfo
                                .getPort());
                        instance 
=   new  SocketClient();
                    } 
catch  (UnknownHostException e) {
                        
//  TODO Auto-generated catch block
                    }  catch  (IOException e) {
                        
//  TODO Auto-generated catch block
                    }
                }
            }
        }
        
return  instance;
    }

    
private  SocketClient() {
        
this .initMap();
        
this .startThread();
    }

    
private   void  initMap() {
        
this .handlerMap  =   new  HashMap < String, Handler > ();
    }

    
public   void  close() {
        
try  {
            client.close();
        } 
catch  (IOException e) {
            
//  TODO Auto-generated catch block
            
// e.printStackTrace();
        }
        instance 
=   null ;
    }
    
    
private   void  startThread() {
        Thread thread 
=   new  Thread() {
            @Override
            
public   void  run() {

                
while  ( true ) {
                    
if  (client  ==   null   ||   ! client.isConnected()) {
                        
continue ;
                    }

                    BufferedReader reader;
                    
try  {
                        reader 
=   new  BufferedReader( new  InputStreamReader(
                                client.getInputStream()));
                        String line 
=  reader.readLine();
                        Log.d(
" initSocket " " line: "   +  line);
                        
if  (line.equals( "" )) {
                            
continue ;
                        }

                        JSONObject json 
=   new  JSONObject(line);
                        String method 
=  json.getString( " Method " );
                        Log.d(
" initSocket " " method: "   +  method);
                        
if  (method.equals( "" )
                                
||   ! handlerMap.containsKey(method)) {
                            Log.d(
" initSocket " " handlerMap not method " );
                            
continue ;
                        }

                        Handler handler 
=  handlerMap.get(method);
                        
if  (handler  ==   null ) {
                            Log.d(
" initSocket " " handler is null " );
                            
continue ;
                        }
                        Log.d(
" initSocket " " handler: "   +  method);
                        Object obj 
=  json.getJSONObject( " Result " );
                        Log.d(
" initSocket " " Result: "   +  obj);
                        Message msg 
=   new  Message();
                        msg.obj 
=  obj;
                        handler.sendMessage(msg);

                    } 
catch  (IOException e) {

                    } 
catch  (JSONException e) {

                    }
                }
            }
        };
        thread.start();
    }

    
private  Map < String, Handler >  handlerMap;

    
public   void  putHandler(String methodnName, Handler handler) {
        
this .removeHandler(methodnName);
        
this .handlerMap.put(methodnName, handler);
    }

    
public   void  removeHandler(String methodnName) {
        
if  ( this .handlerMap.containsKey(methodnName)) {
            
this .handlerMap.remove(methodnName);
        }
    }

    
public   void  logon(String userName) {
        Log.d(
" initSocket " " logon " );
        
try  {
            OutputStreamWriter osw 
=   new  OutputStreamWriter(client
                    .getOutputStream());

            BufferedWriter writer 
=   new  BufferedWriter(osw);

            JSONObject param 
=   new  JSONObject();
            param.put(
" UserName " , userName.replace( " \n " "   " ));

            JSONObject json 
=   this .getJSONData( " Logon " , param);

            writer.write(json.toString());
            writer.flush();
        } 
catch  (IOException e) {
            
//  TODO Auto-generated catch block
            e.printStackTrace();
        } 
catch  (JSONException e) {
            
//  TODO Auto-generated catch block
            e.printStackTrace();
        }
    }

    
public   void  sendMessage(String message) {
        Log.d(
" initSocket " " Send " );
        
try  {
            OutputStreamWriter osw 
=   new  OutputStreamWriter(client
                    .getOutputStream());

            BufferedWriter writer 
=   new  BufferedWriter(osw);

            JSONArray array 
=   new  JSONArray();
            
for  (String item : message.split( " \n " )) {
                array.put(item);
            }

            JSONObject param 
=   new  JSONObject();
            param.put(
" Message " , array);

            param.put(
" UserName " , ChartInfo.getInstance().getUserName());

            JSONObject json 
=   this .getJSONData( " Send " , param);

            writer.write(json.toString());
            writer.flush();
        } 
catch  (IOException e) {
            
//  TODO Auto-generated catch block
            e.printStackTrace();
        } 
catch  (JSONException e) {
            
//  TODO Auto-generated catch block
            e.printStackTrace();
        }
    }

    
private  JSONObject getJSONData(String methodName, JSONObject param) {
        JSONObject json 
=   new  JSONObject();
        
try  {
            json.put(
" Method " , methodName);
            SimpleDateFormat format 
=   new  SimpleDateFormat(
                    
" yyyy-MM-dd HH🇲🇲ss " );
            json.put(
" DateTime " , format.format( new  Date()));
            json.put(
" Param " , param);
            
return  json;
        } 
catch  (JSONException e) {
            
return   null ;
        }
    }
}

 

LogonActivity:

 

package  ld.socket;

import  org.json.JSONException;
import  org.json.JSONObject;

import  android.app.Activity;
import  android.app.AlertDialog;
import  android.content.ComponentName;
import  android.content.DialogInterface;
import  android.content.Intent;
import  android.os.Bundle;
import  android.os.Handler;
import  android.os.Message;
import  android.util.Log;
import  android.view.KeyEvent;
import  android.view.View;
import  android.view.View.OnClickListener;
import  android.widget.Button;
import  android.widget.EditText;

public   class  LogonActivity  extends  Activity {

    
private  EditText edtUserName;
    
private  EditText edtIp;
    
private  EditText edtPort;

    
private  Button btnLogon;

    @Override
    
protected   void  onCreate(Bundle savedInstanceState) {
        
//  TODO Auto-generated method stub
         super .onCreate(savedInstanceState);

        setContentView(R.layout.logon);

        
this .initViews();
    }

    
private   void  initViews() {
        
this .edtUserName  =  (EditText)  this .findViewById(R.id.edtUserName);
        
this .edtIp  =  (EditText)  this .findViewById(R.id.edtIp);
        
this .edtPort  =  (EditText)  this .findViewById(R.id.edtPort);

        
this .btnLogon  =  (Button)  this .findViewById(R.id.btnLogon);
        
this .btnLogon.setOnClickListener( new  OnClickListener() {

            @Override
            
public   void  onClick(View v) {
                
//  TODO Auto-generated method stub

                
//  showAlert(edtUserName.getText().toString());
                 if  (edtUserName.getText().toString().equals( "" )) {
                    showDialog(
" 请输入用户名 " );
                    
return ;
                }

                
if  (edtIp.getText().toString().equals( "" )) {
                    showDialog(
" 请输入IP地址 " );
                    
return ;
                }

                
if  (edtPort.getText().toString().equals( "" )) {
                    showDialog(
" 请输入端口号 " );
                    
return ;
                }

                
int  port  =  Integer.parseInt(edtPort.getText().toString());
                ChartInfo chartInfo 
=  ChartInfo.getInstance();
                chartInfo.setIp(edtIp.getText().toString());
                chartInfo.setPort(port);
                SocketClient proxy 
=  SocketClient.getInstance();

                
if  (proxy  ==   null ) {
                    showDialog(
" 未接入互联网 " );
                    setWireless();
                    
return ;
                }

                proxy.putHandler(
" Logon " new  Handler() {
                    @Override
                    
public   void  handleMessage(Message msg) {

                        SocketClient proxy 
=  SocketClient.getInstance();
                        proxy.removeHandler(
" Logon " );
                        Log.d(
" initSocket " " handleMessage " );
                        
if  (msg  ==   null   ||  msg.obj  ==   null ) {
                            
return ;
                        }

                        JSONObject json 
=  (JSONObject) msg.obj;
                        
try  {
                            String userName 
=  json.getString( " UserName " );
                            Log.d(
" initSocket " " userName: "   +  userName);
                            ChartInfo.getInstance().setUserName(userName);
                            Intent itt 
=   new  Intent();
                            itt
                                    .setClass(LogonActivity.
this ,
                                            MainActivity.
class );
                            LogonActivity.
this .startActivity(itt);
                        } 
catch  (JSONException e) {
                            
//  TODO Auto-generated catch block
                            e.printStackTrace();
                        }
                    }
                });
                proxy.logon(edtUserName.getText().toString());
            }
        });
    }

    
private   void  setWireless() {
        Intent mIntent 
=   new  Intent( " / " );
        ComponentName comp 
=   new  ComponentName( " com.android.settings " ,
                
" com.android.settings.WirelessSettings " );
        mIntent.setComponent(comp);
        mIntent.setAction(
" android.intent.action.VIEW " );
        startActivityForResult(mIntent, 
0 );
    }

    
private   void  showDialog(String mess) {
        
new  AlertDialog.Builder( this ).setTitle( " 信息 " ).setMessage(mess)
                .setNegativeButton(
" 确定 " new  DialogInterface.OnClickListener() {
                    
public   void  onClick(DialogInterface dialog,  int  which) {
                    }
                }).show();
    }

    @Override
    
public   boolean  onKeyDown( int  keyCode, KeyEvent event) {

        
if  (keyCode  ==  KeyEvent.KEYCODE_BACK  &&  event.getRepeatCount()  ==   0 ) {

            AlertDialog alertDialog 
=   new  AlertDialog.Builder(
                    LogonActivity.
this ).setTitle( " 退出程序 " ).setMessage( " 是否退出程序 " )
                    .setPositiveButton(
" 确定 " ,
                            
new  DialogInterface.OnClickListener() {

                                
public   void  onClick(DialogInterface dialog,
                                        
int  which) {
                                    LogonActivity.
this .finish();
                                }

                            }).setNegativeButton(
" 取消 " ,

                    
new  DialogInterface.OnClickListener() {
                        
public   void  onClick(DialogInterface dialog,  int  which) {
                            
return ;
                        }
                    }).create(); 
//  创建对话框

            alertDialog.show(); 
//  显示对话框

            
return   false ;

        }

        
return   false ;
    }

    @Override
    
protected   void  onDestroy() {
        
//  TODO Auto-generated method stub
         super .onDestroy();
        SocketClient proxy 
=  SocketClient.getInstance();
        
if  (proxy  !=   null ) {
            proxy.close();
        }
    }

}

 

 

MainActivity:

 

package  ld.socket;

import  org.json.JSONException;
import  org.json.JSONObject;

import  android.app.Activity;
import  android.app.AlertDialog;
import  android.content.DialogInterface;
import  android.os.Bundle;
import  android.os.Handler;
import  android.os.Message;
import  android.util.Log;
import  android.view.KeyEvent;
import  android.view.View;
import  android.view.WindowManager;
import  android.view.View.OnClickListener;
import  android.widget.Button;
import  android.widget.EditText;
import  android.widget.ListView;

public   class  MainActivity  extends  Activity {

    
private  EditText edtMessage;

    
private  Button btnSend;

    
private  ListView ltvMessage;

    
private  MessageAdapter adapter;

    
/**  Called when the activity is first created.  */
    @Override
    
public   void  onCreate(Bundle savedInstanceState) {
        
super .onCreate(savedInstanceState);
        setContentView(R.layout.main);

        
//  隐藏键盘
         this .getWindow().setSoftInputMode(
                WindowManager.LayoutParams.SOFT_INPUT_STATE_ALWAYS_HIDDEN);

        Log.d(
" initSocket " " MessageAdapter " );
        
this .adapter  =   new  MessageAdapter( this );
        Log.d(
" initSocket " " adapter is ok " );

        
this .findThisViews();
        
this .initHandler();

        
this .serOnClick();

        Log.d(
" initSocket " " onCreate " );
    }

    
private   void  findThisViews() {
        
this .edtMessage  =  (EditText)  this .findViewById(R.id.edtMessage);
        
this .btnSend  =  (Button)  this .findViewById(R.id.btnSend);

        
this .ltvMessage  =  (ListView)  this .findViewById(R.id.ltvMessage);
        
//  this.ltvMessage.setEnabled(false);
         this .ltvMessage.setAdapter( this .adapter);
    }

    
private   void  initHandler() {

        Handler handler 
=   new  Handler() {
            @Override
            
public   void  handleMessage(Message msg) {
                
if  (msg.obj  ==   null ) {
                    Log.d(
" initSocket " " handleMessage is null " );
                    
return ;
                }

                Log.d(
" initSocket " " handleMessage " );
                
try  {
                    JSONObject json 
=  (JSONObject) msg.obj;
                    String userName 
=  json.getString( " UserName " );

                    StringBuilder sb 
=   new  StringBuilder();
                    
int  length  =  json.getJSONArray( " Message " ).length();
                    
for  ( int  i  =   0 ; i  <  length; i ++ ) {
                        String item 
=  json.getJSONArray( " Message " ).getString(i);
                        
if  (item.equals( "" )) {
                            
continue ;
                        }
                        
if  (length  >  i  +   1 ) {
                            Log.d(
" initSocket " " length: "   +  length);
                            Log.d(
" initSocket " " i: "   +  i);
                            Log.d(
" initSocket " " item: "   +  item);
                            item 
+=   " \n " ;
                        }
                        sb.append(item);
                    }

                    MessageRecord record 
=   new  MessageRecord();
                    record.setUserName(userName);
                    record.setMessage(sb.toString());

                    MainActivity.
this .adapter.add(record);
                    adapter.notifyDataSetChanged();
                } 
catch  (JSONException e) {
                    
//  TODO Auto-generated catch block
                    e.printStackTrace();
                }
            }
        };
        SocketClient proxy 
=  SocketClient.getInstance();
        proxy.putHandler(
" Send " , handler);
    }

    
private   void  serOnClick() {
        
this .btnSend.setOnClickListener( new  OnClickListener() {

            @Override
            
public   void  onClick(View v) {
                
//  TODO Auto-generated method stub
                btnSend.setEnabled( false );
                String txt 
=  edtMessage.getText().toString();
                
if  (txt.equals( "" )) {
                    btnSend.setEnabled(
true );
                    
return ;
                }
                SocketClient proxy 
=  SocketClient.getInstance();
                proxy.sendMessage(txt);
                edtMessage.setText(
"" );
                btnSend.setEnabled(
true );
            }
        });
    }

    @Override
    
public   boolean  onKeyDown( int  keyCode, KeyEvent event) {

        
if  (keyCode  ==  KeyEvent.KEYCODE_BACK  &&  event.getRepeatCount()  ==   0 ) {

            AlertDialog alertDialog 
=   new  AlertDialog.Builder(
                    MainActivity.
this ).setTitle( " 询问 " ).setMessage( " 是否注销登录? " )
                    .setPositiveButton(
" 确定 " ,
                            
new  DialogInterface.OnClickListener() {

                                
public   void  onClick(DialogInterface dialog,
                                        
int  which) {
                                    MainActivity.
this .finish();
                                }

                            }).setNegativeButton(
" 取消 " ,

                    
new  DialogInterface.OnClickListener() {
                        
public   void  onClick(DialogInterface dialog,  int  which) {
                            
return ;
                        }
                    }).create(); 
//  创建对话框

            alertDialog.show(); 
//  显示对话框

            
return   false ;

        }

        
return   false ;
    }
}

 

 五、运行效果

 

 

 

 

  代码下载

  出处:http://www.cnblogs.com/GoodHelper/archive/2011/07/08/android_socket_chart.html

  欢迎转载,但需保留版权!


原文链接:http://www.cnblogs.com/GoodHelper/archive/2011/07/08/android_socket_chart.html
加载中
0
尐帥鱼
尐帥鱼

为什么我写的java和wp7通信的socket 会阻塞呢 ?java端一直不能跳出循环,wp7发信息给java服务器的时候我在末尾加上了“\r”  ,但是服务端还是阻塞

0
lython
lython

不错不错!

返回顶部
顶部