C# Socket通信的服务器与客户端

客户端代码:

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Net;
using System.Net.Sockets;
using System.Threading;
namespace ClientSocket
{
    class Program
    {
        private static byte[] result = new byte[1024];
        static void Main(string[] args)
        {
            //设定服务器IP地址
            IPAddress ip = IPAddress.Parse("127.0.0.1");
            Socket clientSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
            try
            {
                clientSocket.Connect(new IPEndPoint(ip, 8885)); //配置服务器IP与端口
                Console.WriteLine("连接服务器成功");
            }
            catch
            {
                Console.WriteLine("连接服务器失败,请按回车键退出!");
                return;
            }
            for (int i = 0; i < 10; i++)
            {
                try
                {
                    Thread.Sleep(1000);    //等待1秒钟
                    string sendMessage = "client send Message Hellp" + DateTime.Now;
                    clientSocket.Send(Encoding.ASCII.GetBytes(sendMessage));
                    Console.WriteLine("向服务器发送消息:{0}" + sendMessage);
                }
                catch
                {
                    clientSocket.Shutdown(SocketShutdown.Both);
                    clientSocket.Close();
                    break;
                }
            }
            Console.WriteLine("发送完毕,按回车键退出");
            Console.ReadLine();
        }
    }
}

服务器端代码

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Net.Sockets;
using System.Net;
using System.Threading;
using LogHelper;
using System.IO;
using System.Diagnostics;
namespace SocketForm
{
    class SocketConnection
    {
        private int port;//监听端口号
        private static byte[] result = new byte[1024];
        private static Socket server;//服务器Socket
        private IPAddress ip;//Ip地址
        private static Socket client;//客户端Socket
        private static Thread myThread;//启动监听线程
        private static Thread receiveThread;//接收数据线程
        public SocketConnection(string ipadr,int port)
        {
            this.port = port;//初始化端口
            ip = IPAddress.Parse(ipadr);//初始化ip地址

        }
        public void setConnection()
        {
            server = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);//实例化socket对象(采用网络流传输方式,TCP协议传输)
            server.Bind(new IPEndPoint(ip, port));//绑定ip及端口
            Console.WriteLine("绑定端口ip"+this.ip+":"+this.port);
            server.Listen(10);//监听端口
            Console.WriteLine("正在监听IP"+this.ip+"  端口:"+this.port+"......");
            Log.Errorname = "Info";
            Log.CreateLogTxt("监听Ip"+this.ip+"端口"+this.port+"......");
            myThread = new Thread(ListenClientConnect);
            myThread.Start();
        }

        private static void ListenClientConnect()
        {
            while (true)
            {
                client = server.Accept();
                receiveThread = new Thread(ReceiveMessage);
                receiveThread.Start(client);
            }
        }

        /// <summary>
        /// 接收消息
        /// </summary>
        /// <param name="clientSocket"></param>
        private static void ReceiveMessage(object clientSocket)
        {

           client = (Socket)clientSocket;
            while (true)
            {
                try
                {
                    //通过clientSocket接收数据
                    int receiveNumber = client.Receive(result);//获取接收数据的长度
                    StreamWriter resultMessage = new StreamWriter("out.txt", true);//输出流实例化
                    resultMessage.WriteLine("接收客户端{0}消息{1}", client.RemoteEndPoint.ToString(), Encoding.ASCII.GetString(result, 0, receiveNumber));
                    resultMessage.Close();
                    Log.Errorname = "Info";
                    Log.CreateLogTxt("信息获取成功");
                    Console.WriteLine("信息获取成功");
                }
                catch (Exception ex)
                {
                    Log.Errorname = "ERROR";
                    Log.CreateLogTxt("从服务器获取数据错误"+"错误信息"+ex.Message);
                    Console.WriteLine("从服务器获取数据错误" + "错误信息" + ex.Message);
                    client.Shutdown(SocketShutdown.Both);
                    client.Close();
                    break;
                }
            }
        }  

    }
}
时间: 2024-10-14 00:47:34

C# Socket通信的服务器与客户端的相关文章

python socket之tcp服务器与客户端demo

python socket之tcp服务器与客户端demo 作者:vpoet 日期:夏季 server: # -*- coding: cp936 -*- ''' 建立一个python server,监听指定端口, 如果该端口被远程连接访问,则获取远程连接,然后接收数据, 并且做出相应反馈. ''' import socket if __name__=="__main__": print "Server is starting" sock = socket.socket

JAVA基础知识之网络编程——-TCP/IP协议,socket通信,服务器客户端通信demo

OSI模型分层 OSI模型是指国际标准化组织(ISO)提出的开放系统互连参考模型(Open System Interconnection Reference Model,OSI/RM),它将网络分为七层:物理层,数据链路层,网络层,传输层,会话层,表示层,应用层 TCP/IP协议 TCP/IP是一系列网络通信协议的统称,其中最核心的两个协议是TCP和IP.TCP称为传输控制协议,IP称为互联网络协议. 网络分层除了OSI模型分层,还有TCP/IP模型分层,将网络划分为四层,应用层.传输层.网际层

Socket通信服务端和客户端总结

服务端:1.创建一个Socket对象.用来侦听的.2.绑定端口和IP3.开启侦听4.开始接受客户端连接5.创建一个代理通信Socket对象.用来通信的.6.发送消息接收消息7.收到客户端的道别,也会回一个:我也走了8.关闭Socket 客户端:1.创建Socket对象2.连接服务器3.发送消息接受消息4.停止连接服务器和客户端都可以.发消息:我要走了.5.关闭Socket

socket,实现服务器和客户端对话

服务器: #define _CRT_SECURE_NO_WARNINGS#include<stdio.h>#include<string>#include<WinSock2.h> //网络库用2.2版本 目前系统的最高版本#pragma comment(lib,"Ws2_32.lib") //加载动态连接库 x32.x64都是用ws2_32.lib这一个版本//上面为第二版 第一版头文件为WinSock.h 动态库为wsock32.libusing

socket编程之服务器和客户端

服务端和客户端就像银行出纳员和客户样,一个银行出纳员(服务器),不吃不睡的服务排队的客户,每个客户都会有要解决的问题,一旦完成,客户就会走开,出纳员等待下一个客户的到来. 服务器端: from socket import * from time import ctime HOST = '' #空白,是对bind方法的标识,可以使用任何可用的地址 PORT = 21567 BUFSIZ = 1024 #缓冲区大小设为1kb ADDR = (HOST, PORT) tcpSerSock = sock

相见恨晚--Socket通信

第一次接触Socket是大二时的课程设计,当时做的是图书管理系统,源码都是网上下载,考试周拿着代码天天磨,隐约中记得有Socket这么一个单词. 第二次是去年代表学校参加"河北省电子信息职业技能大赛",接受曹建新师哥的培训.建新师哥当时用手机Android软件做客户端,通过局域网向电脑端服务器传输手机录入的信息.当时我很诧异,客户端是Android平台,服务器是.Net平台,这两种平台是如何在局域网内进行通信的呢?建新师哥的回答是:"通过Socket,把数据打包成JSON格式

Linux - 面向连接的socket通信流程

字符串的IP与32的IP的转换 说明 网络上的IP都是数字加点(192.168.0.1)构成 struct in_addr结构使用32位的IP,如 IP(C0A80001)是192.168.0.1 函数原型 int inet_aton(const char *cp, struct in_addr *inp) 将a.b.c.d的IP转换为32位的IP,存储在 inp指针里面 char *inet_ntoa(struct in_addr in) 将32位IP转换为a.b.c.d的格式 说明 a代表

windows phone 8.1开发:socket通信聊天

本例用WPF程序做服务器端,windows phone程序做客户端.我们使用基于UDP协议的Socket通信.更多关于socket信息请查看:http://msdn.microsoft.com/zh-cn/library/system.net.sockets.socket(v=vs.110).aspx 我们使用DatagramSocket类完成UDP通信功能. 具体代码如下:(前台代码就不帖出来了,下面只给出后台代码和一些注释.完整源代码会在论坛发出来,地址在文章最后.) socket通信聊天w

Socket 通信原理(Android客户端和服务器以TCP&amp;&amp;UDP方式互通)

ZERO.前言 有关通信原理内容是在网上或百科整理得到,代码部分为本人所写,如果不当,还望指教. 一.Socket通信简介 Android与服务器的通信方式主要有两种,一是Http通信,一是Socket通信.两者的最大差异在于,http连接使用的是“请求—响应方式”,即在请求时建立连接通道,当客户端向服务器发送请求后,服务器端才能向客户端返回数据.而Socket通信则是在双方建立起连接后就可以直接进行数据的传输,在连接时可实现信息的主动推送,而不需要每次由客户端想服务器发送请求. 那么,什么是s