云主机 多 网站,网站图片设计效果图,旅游网站的功能,个人可以做导购网站吗SOCKET通信的基本步骤 1#xff09;建立一个服务器ServerSocket#xff0c;并同时定义好ServerSocket的监听端口#xff1b;2#xff09;ServerSocket 调用accept()方法#xff0c;使之处于阻塞。3#xff09;创建一个客户机Socket,并设置好服务器的IP和端口。4#xff… SOCKET通信的基本步骤 1建立一个服务器ServerSocket并同时定义好ServerSocket的监听端口 2ServerSocket 调用accept()方法使之处于阻塞。 3创建一个客户机Socket,并设置好服务器的IP和端口。 4客户机发出连接请求建立连接。 5分别取得服务器和客户端ServerSocket 和Socket的InputStream和OutputStream. 6) 利用Socket和ServerSocket进行数据通信。 / 在进行网络编程时我们常常见到同步(Sync)/异步(Async)阻塞(Block)/非阻塞(Unblock)四种调用方式 同步 所谓同步就是在发出一个功能调用时在没有得到结果之前该调用就不返回。也就是必须一件一件事做,等前一件做完了才能做下一件事。 例如普通B/S模式同步提交请求-等待服务器处理-处理完毕返回 这个期间客户端浏览器不能干任何事 异步 异步的概念和同步相对。当一个异步过程调用发出后调用者不能立刻得到结果。实际处理这个调用的部件在完成后通过状态、通知和回调来通知调用者。 例如 ajax请求异步: 请求通过事件触发-服务器处理这是浏览器仍然可以作其他事情-处理完毕 阻塞 阻塞调用是指调用结果返回之前当前线程会被挂起线程进入非可执行状态在这个状态下cpu不会给线程分配时间片即线程暂停运行。函数只有在得到结果之后才会返回。 有人也许会把阻塞调用和同步调用等同起来实际上他是不同的。对于同步调用来说很多时候当前线程还是激活的只是从逻辑上当前函数没有返回而已。 例如我们在socket中调用recv函数如果缓冲区中没有数据这个函数就会一直等待直到有数据才返回。而此时当前线程还会继续处理各种各样的消息。 非阻塞 非阻塞和阻塞的概念相对应指在不能立刻得到结果之前该函数不会阻塞当前线程而会立刻返回。 对象的阻塞模式和阻塞函数调用 对象是否处于阻塞模式和函数是不是阻塞调用有很强的相关性但是并不是一一对应的。阻塞对象上可以有非阻塞的调用方式我们可以通过一定的API去轮询状 态在适当的时候调用阻塞函数就可以避免阻塞。而对于非阻塞对象调用特殊的函数也可以进入阻塞调用。函数select就是这样的一个例子。 1. 同步就是我调用一个功能该功能没有结束前我死等结果。 2. 异步就是我调用一个功能不需要知道该功能结果该功能有结果后通知我回调通知 3. 阻塞 就是调用我函数我函数没有接收完数据或者没有得到结果之前我不会返回。 4. 非阻塞 就是调用我函数我函数立即返回通过select通知调用者 同步IO和异步IO的区别就在于数据拷贝的时候进程是否阻塞 阻塞IO和非阻塞IO的区别就在于应用程序的调用是否立即返回 对于举个简单c/s 模式 同步提交请求-等待服务器处理-处理完毕返回这个期间客户端浏览器不能干任何事 异步请求通过事件触发-服务器处理这是浏览器仍然可以作其他事情-处理完毕 同步和异步都只针对于本机SOCKET而言的。 同步和异步,阻塞和非阻塞,有些混用,其实它们完全不是一回事,而且它们修饰的对象也不相同。 阻塞和非阻塞是指当进程访问的数据如果尚未就绪,进程是否需要等待,简单说这相当于函数内部的实现区别,也就是未就绪时是直接返回还是等待就绪; 而同步和异步是指访问数据的机制,同步一般指主动请求并等待I/O操作完毕的方式,当数据就绪后在读写的时候必须阻塞(区别就绪与读写二个阶段,同步的读写必须阻塞),异步则指主动请求数据后便可以继续处理其它任务,随后等待I/O,操作完毕的通知,这可以使进程在数据读写时也不阻塞。(等待通知) // 客户端 综合运用以上阐述的使用Visual C#进行Socket网络程序开发的知识下面的程序段完整地实现了Web页面下载功能。用户只需在窗体上输入远程主机名Dns 主机名或以点分隔的四部分表示法格式的 IP 地址和预保存的本地文件名并利用专门提供Http服务的80端口就可以获取远程主机页面并保存在本地机指定文件中。如果保存格式是.htm格式你就可以在Internet浏览器中打开该页面。适当添加代码你甚至可以实现一个简单的浏览器程序。 实现此功能的主要源代码如下 //开始按钮事件 private void button1_Click(object sender, System.EventArgs e) { //取得预保存的文件名 string fileNametextBox3.Text.Trim(); //远程主机 string hostNametextBox1.Text.Trim(); //端口 int portInt32.Parse(textBox2.Text.Trim()); //得到主机信息 IPHostEntry ipInfoDns.GetHostByName(hostName); //取得IPAddress[] IPAddress[] ipAddripInfo.AddressList; //得到ip IPAddress ipipAddr[0]; //组合出远程终结点 IPEndPoint hostEPnew IPEndPoint(ip,port); //创建Socket 实例 Socket socketnew Socket(AddressFamily.InterNetwork,SocketType.Stream,ProtocolType.Tcp); try { //尝试连接 socket.Connect(hostEP); } catch(Exception se) { MessageBox.Show(连接错误se.Message,提示信息 ,MessageBoxButtons.RetryCancel,MessageBoxIcon.Information); } //发送给远程主机的请求内容串 string sendStrGET / HTTP/1.1\r\nHost: hostName \r\nConnection: Close\r\n\r\n; //创建bytes字节数组以转换发送串 byte[] bytesSendStrnew byte[1024]; //将发送内容字符串转换成字节byte数组 bytesSendStrEncoding.ASCII.GetBytes(sendStr); try { //向主机发送请求 socket.Send(bytesSendStr,bytesSendStr.Length,0); } catch(Exception ce) { MessageBox.Show(发送错误:ce.Message,提示信息 ,MessageBoxButtons.RetryCancel,MessageBoxIcon.Information); } //声明接收返回内容的字符串 string recvStr; //声明字节数组一次接收数据的长度为1024字节 byte[] recvBytesnew byte[1024]; //返回实际接收内容的字节数 int bytes0; //循环读取直到接收完所有数据 while(true) { bytessocket.Receive(recvBytes,recvBytes.Length,0); //读取完成后退出循环 if(bytes0) break; //将读取的字节数转换为字符串 recvStrEncoding.ASCII.GetString(recvBytes,0,bytes); } //将所读取的字符串转换为字节数组 byte[] contentEncoding.ASCII.GetBytes(recvStr); try { //创建文件流对象实例 FileStream fsnew FileStream(fileName,FileMode.OpenOrCreate,FileAccess.ReadWrite); //写入文件 fs.Write(content,0,content.Length); } catch(Exception fe) { MessageBox.Show(文件创建/写入错误:fe.Message,提示信息,MessageBoxButtons.RetryCancel,MessageBoxIcon.Information); } //禁用Socket socket.Shutdown(SocketShutdown.Both); //关闭Socket socket.Close(); } } // /client端 using System; using System.Text; using System.IO; using System.Net; using System.Net.Sockets; namespace socketsample { class Class1 { static void Main() { try { int port 2000; string host 127.0.0.1; IPAddress ip IPAddress.Parse(host); IPEndPoint ipe new IPEndPoint(ip, port); Socket c new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp); c.Connect(ipe); string sendStr hello!This is a socket test; byte[] bs Encoding.ASCII.GetBytes(sendStr); c.Send(bs, bs.Length, 0); string recvStr ; byte[] recvBytes new byte[1024]; int bytes; bytes c.Receive(recvBytes, recvBytes.Length, 0); recvStr Encoding.ASCII.GetString(recvBytes, 0, bytes); Console.WriteLine(recvStr); c.Close(); } catch (ArgumentNullException e) { Console.WriteLine(ArgumentNullException: {0}, e); } catch (SocketException e) { Console.WriteLine(SocketException: {0}, e); } Console.ReadLine(); } } } //server端 using System; using System.Text; using System.IO; using System.Net; using System.Net.Sockets; namespace Project1 { class Class2 { static void Main() { try { int port 2000; 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); s.Bind(ipe); s.Listen(0); Socket temp s.Accept(); string recvStr ; byte[] recvBytes new byte[1024]; int bytes; bytes temp.Receive(recvBytes, recvBytes.Length, 0); recvStr Encoding.ASCII.GetString(recvBytes, 0, bytes); Console.WriteLine(recvStr); string sendStr Ok!Sucess!; byte[] bs Encoding.ASCII.GetBytes(sendStr); temp.Send(bs, bs.Length, 0); temp.Shutdown(SocketShutdown.Both); temp.Close(); s.Shutdown(SocketShutdown.Both); s.Close(); } catch (ArgumentNullException e) { Console.WriteLine(ArgumentNullException: {0}, e); } catch (SocketException e) { Console.WriteLine(SocketException: {0}, e); } Console.ReadLine(); } } }
