C#PC端TCP/IP与安卓通信源代码

标签：

控制台程序：

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using System.Net;
using System.Net.Sockets;
using ConsoleApplication1;

namespace ConsoleApplication1
{
        public static class SocketTest
        {
            private static Encoding encode = Encoding.Default;

            /// <summary>
            /// 监听请求
            /// </summary>
            /// <param name="port"></param>
            public static void Listen(int port)
            {
                Socket listenSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
                listenSocket.Bind(new IPEndPoint(IPAddress.Any, port));
                listenSocket.Listen(100);
                Console.WriteLine("Listen " + port + " ...");
                while (true)
                {
                    Socket acceptSocket = listenSocket.Accept();
                    string receiveData = Receive(acceptSocket, 5000); //5 seconds timeout.
                    Console.WriteLine("Receive：" + receiveData);
                    acceptSocket.Send(encode.GetBytes("ok"));
                    DestroySocket(acceptSocket); //import
                }
            }
            /// <summary>
            /// 发送数据
            /// </summary>
            /// <param name="host"></param>
            /// <param name="port"></param>
            /// <param name="data"></param>
           /// <returns></returns>
            public static string Send(string host, int port, string data)
            {
                string result = string.Empty;
                Socket clientSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
                clientSocket.Connect(host, port);
                clientSocket.Send(encode.GetBytes(data));
                Console.WriteLine("Send：" + data);
                result = Receive(clientSocket, 5000 * 2); //5*2 seconds timeout.
                Console.WriteLine("Receive：" + result);
                DestroySocket(clientSocket);
                return result;
            }
            /// <summary>
            /// 接收数据
            /// </summary>
            /// <param name="socket"></param>
            /// <param name="timeout"></param>
            /// <returns></returns>
            private static string Receive(Socket socket, int timeout)
            {
                string result = string.Empty;
                socket.ReceiveTimeout = timeout;
                List<byte> data = new List<byte>();
                byte[] buffer = new byte[1024];
                int length = 0;
                try
                {
                    while ((length = socket.Receive(buffer)) > 0)
                    {
                        for (int j = 0; j < length; j++)
                        {
                            data.Add(buffer[j]);
                        }
                        if (length < buffer.Length)
                        {
                            break;
                        }
                    }
                }
               catch { }
                if (data.Count > 0)
                {
                    result = encode.GetString(data.ToArray(), 0, data.Count);
                }
                return result;
            }
            /// <summary>
           /// 销毁Socket对象
            /// </summary>
            /// <param name="socket"></param>
            private static void DestroySocket(Socket socket)
            {
                if (socket.Connected)
                {
                    socket.Shutdown(SocketShutdown.Both);
                }
                socket.Close();
            }
        }
    }
    class Program
    {
        static void Main(string[] args)
        {
            SocketTest.Listen(9876);
        }
    }

C#PC端TCP/IP与安卓通信源代码

标签：

原文地址：http://www.cnblogs.com/liyu925/p/4398589.html