using System;

using System.Text;

using System.IO;

using System.Net;

using System.Net.Sockets;

namespace SocketOne

{

    class MyServer

    {

        static void Main(string[] args)

        {

            try

            {

                int port = ;

                string host = "127.0.0.1";

                IPAddress ip = IPAddress.Parse(host);

                IPEndPoint ipe = new IPEndPoint(ip, port);

                Socket s = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);//创建一个Socket类

                s.Bind(ipe);//绑定8081端口

                s.Listen();//开始监听

                Console.WriteLine("Wait for connect");

                Socket temp = s.Accept();//为新建连接创建新的Socket。

                Console.WriteLine("Get a connect");

                string recvStr = "";

                string sendStr = "";

                //接收传送信息的时候都是发送的byte数组

                //首先向客户端发送信息

                sendStr = "Connection set up";

                //与java通信 后面加个\n  因为我的java用的是readline

                byte[] bs = Encoding.ASCII.GetBytes(sendStr + "\n");

                temp.Send(bs, bs.Length, );//返回客户端成功信息

                int count = ;

                MyResponse myresponse=new MyResponse();

                while (true)

                {

                    Console.WriteLine("a loop starts count="+ (count++) +"==================");

                    //接收信息

                    int bytes;

                    byte[] recvBytes = new byte[];

                    bytes = temp.Receive(recvBytes, recvBytes.Length, );//从客户端接受信息

                    recvStr = Encoding.ASCII.GetString(recvBytes, , bytes);//

                    Console.WriteLine("Server Get Message:{0}", recvStr);//把客户端传来的信息显示出来

                    //经过我的处理后将信息返回给客户端

                    sendStr = myresponse.myresponse(recvStr);

                    Console.WriteLine("response is " + sendStr);

                    bs = Encoding.ASCII.GetBytes(sendStr + "\n");

                    temp.Send(bs, bs.Length, );//返回客户端成功信息

                    Console.WriteLine("this loop end");

                }

                //temp.Close();

                //s.Close();

            }

            catch (ArgumentNullException e)

            {

                Console.WriteLine("ArgumentNullException: {0}", e);

            }

            catch (SocketException e)

            {

                Console.WriteLine("SocketException: {0}", e);

            }

            Console.WriteLine("Press Enter to Exit");

            Console.ReadLine();

        }

    }

}

package mypackage.hello;

import java.io.BufferedReader;

import java.io.IOException;

import java.io.InputStreamReader;

import java.io.PrintWriter;

import java.net.Socket;

import java.net.UnknownHostException;

import android.app.Activity;

import android.os.Bundle;

import android.view.View;

import android.view.View.OnClickListener;

import android.widget.Button;

public class Hello1Activity extends Activity {

    /** Called when the activity is first created. */

    @Override

    public void onCreate(Bundle savedInstanceState) {

        super.onCreate(savedInstanceState);

        setContentView(R.layout.main);

        initBtns();

        connectToServer();

    }

    Button btnAdd;

    Button btnDel;

    Button btnSearch;

    Socket socket;

    BufferedReader in;

    PrintWriter out;

    String recvStr = null;

    String sendStr = null;

    public void initBtns() {

        btnAdd = (Button) findViewById(R.id.buttonAdd);

        btnDel = (Button) findViewById(R.id.buttonDel);

        btnSearch = (Button) findViewById(R.id.buttonSearch);

        btnAdd.setOnClickListener(new OnClickListener() {

            public void onClick(View v) {

                try {

                    System.out.println("add clicked");

                    sendStr = "add,xxx,xxx,xxx";

                    out.println(sendStr);

                    recvStr = in.readLine();

                    System.out.println("response is " + recvStr);

                } catch (IOException e) {

                    // TODO Auto-generated catch block

                    e.printStackTrace();

                }

            }

        });

        btnDel.setOnClickListener(new OnClickListener() {

            public void onClick(View v) {

                try {

                    System.out.println("del clicked");

                    sendStr = "DEL,xxx";

                    out.println(sendStr);

                    recvStr = in.readLine();

                    System.out.println("response is " + recvStr);

                } catch (IOException e) {

                    e.printStackTrace();

                }

            }

        });

        btnSearch.setOnClickListener(new OnClickListener() {

            public void onClick(View v) {

                try {

                    System.out.println("search clicked");

                    sendStr = "search,xxx";

                    out.println(sendStr);

                    recvStr = in.readLine();

                    System.out.println("response is " + recvStr);

                } catch (IOException e) {

                    // TODO Auto-generated catch block

                    e.printStackTrace();

                }

            }

        });

    }

    public void connectToServer() {

        try {

            // 同时 为了使程序拥有网络权限 在manifest中要有 <uses-permission

            // android:name="android.permission.INTERNET" />

            // 否则提示 permission denied

            // 安卓模拟器将127.0.0.1默认为模拟器的本机地址 要得到计算机中真正的地址是 localhost/127.0.0.1 或者

            // 10.0.0.2

            socket = new Socket("10.0.2.2", 8081);

            System.out.println("after socket");

            in = new BufferedReader(new InputStreamReader(

                    socket.getInputStream()));

            out = new PrintWriter(socket.getOutputStream(), true);

            BufferedReader line = new BufferedReader(new InputStreamReader(

                    System.in));

        } catch (UnknownHostException e) {

            // TODO Auto-generated catch block

            e.printStackTrace();

        } catch (IOException e) {

            // TODO Auto-generated catch block

            e.printStackTrace();

        }

    }

}