using SystemNetSockets;
static void Main(string[] args)//服务器段
{
int port = 2000;
string host = "127001";
//
///创建终结点(EndPoint)
IPAddress ip = IPAddressParse(host);//把ip地址字符串转换为IPAddress类型的实例
IPEndPoint ipe = new IPEndPoint(ip, port);//用指定的端口和ip初始化IPEndPoint类的新实例
//
///创建socket并开始监听
Socket s = new Socket(AddressFamilyInterNetwork, SocketTypeStream, ProtocolTypeTcp);//创建一个socket对像,如果用udp协议,则要用SocketTypeDgram类型的套接字
sBind(ipe);//绑定EndPoint对像(2000端口和ip地址)
sListen(0);//开始监听
ConsoleWriteLine("等待客户端连接");
//
///接受到client连接,为此连接建立新的socket,并接受信息
Socket temp = sAccept();//为新建连接创建新的socket
ConsoleWriteLine("建立连接");
string recvStr = "";
byte[] recvBytes = new byte[1024];
int bytes;
bytes = tempReceive(recvBytes, recvBytesLength, 0);//从客户端接受信息
recvStr += EncodingASCIIGetString(recvBytes, 0, bytes);
//
///给client端返回信息
ConsoleWriteLine("server get message:{0}", recvStr);//把客户端传来的信息显示出来
string sendStr = "ok!Client send message successful!";
byte[] bs = EncodingASCIIGetBytes(sendStr);
tempSend(bs, bsLength, 0);//返回信息给客户端
tempClose();
sClose();
ConsoleReadLine();
}
static void Main(string[] args)//客户端
{
try
{
int port = 2000;
string host = "127001";
//
///创建终结点EndPoint
IPAddress ip = IPAddressParse(host);
//IPAddress ipp = new IPAddress("127001");
IPEndPoint ipe = new IPEndPoint(ip, port);//把ip和端口转化为IPEndpoint实例
//
///创建socket并连接到服务器
Socket c = new Socket(AddressFamilyInterNetwork, SocketTypeStream, ProtocolTypeTcp);//创建Socket
ConsoleWriteLine("Conneting…");
cConnect(ipe);//连接到服务器
//
///向服务器发送信息
string sendStr = "hello!This is a socket test";
byte[] bs = EncodingASCIIGetBytes(sendStr);//把字符串编码为字节
ConsoleWriteLine("Send Message");
cSend(bs, bsLength, 0);//发送信息
//
///接受从服务器返回的信息
string recvStr = "";
byte[] recvBytes = new byte[1024];
int bytes;
bytes = cReceive(recvBytes, recvBytesLength, 0);//从服务器端接受返回信息
recvStr += EncodingASCIIGetString(recvBytes, 0, bytes);
ConsoleWriteLine("client get message:{0}", recvStr);//显示服务器返回信息
//
///一定记着用完socket后要关闭
cClose();
}
catch (ArgumentNullException e)
{
ConsoleWriteLine("argumentNullException: {0}", e);
}
catch (SocketException e)
{
ConsoleWriteLine("SocketException:{0}", e);
}
ConsoleWriteLine("Press Enter to Exit");
}
粘包是因为发送太快了,可以通过发送固定长度数据包和在数据包前后加标识以做截取解决。
给你介绍第一种方法,发送固定长度的数据包,不足长度的补数,这种方法要固定读取N长度的数据
整体说按类型分,可以分为头包,一般包,尾包
这三种数据包的格式可以这样包头+实际数据+检验位
1 头包,比如可以是A01:LXXXXXXXXXXXC
包头可以用包头标识+第几帧+开始截取标志+文件长度L构成,例子中是A01:),L为所有数据包加起来的实际数据总长度,XXXXXXXX为实际数据占 N字节(N为固定字节,这个你自己定义大小),C为校验位占一个字节,即所有数据的累加和
2 一般包,格式可以为P02:XXXXXXXXXXXXC
类似包头格式,P为一般包标识,02表示第二个包
3 包尾,格式可以为D03:XXXXXFFFFFFC
此处XXXXX为实际数据,FFFFF为不足N位的补数,最后一个包是多长可以通过头包L跟尾包算出来
各种校验
1 收到的数据包要做校验位验证,就是格式中的C
2 每次收到包要判断是不是期望的包,通过第几个包来判断,比如你要收第4个包了,但你收到了P05,那就重新请求一次要收第四个包,或者是直接失败
3 其他校验,具体情况具体分析
第二种数据包前后加标识以做截取解决也是类似的,就是在实际数据前后加上一些供你判断的标识,思路已经在这里了,具体格式要自己定义,因为你是程序员
1、要实现网络编程,首先得了解网络编程的原理。
大部分网络编程底层都是通过TCP/IP或者UDP协议进行通讯,不管是TCP还是UDP通讯,都是通过调用socket实现的。
Socket是应用层与TCP/IP协议族通信的中间软件抽象层,它是一组接口。在设计模式中,Socket其实就是一个门面模式,它把复杂的TCP/IP协议族隐藏在Socket接口后面,对用户来说,一组简单的接口就是全部,让Socket去组织数据,以符合指定的协议。
Socket通讯分为两部分:服务器端和客户端,服务器端监听客户端的连接,连接上之后,实现数据通讯,流程
2、用C语言调用Socket实现通讯
服务器端示例代码如下:
#include
#include
#include
#include
#include
#include
#include
#include
#definePORT1500//端口号
#defineBACKLOG5/最大监听数/
intmain(){
intsockfd,new_fd;/socket句柄和建立连接后的句柄/
structsockaddr_inmy_addr;/本方地址信息结构体,下面有具体的属性赋值/
structsockaddr_intheir_addr;/对方地址信息/
intsin_size;
sockfd=socket(AF_INET,SOCK_STREAM,0);//建立socket
if(sockfd==-1){
printf(\"socketfailed:%d
Socket,又称为套接字,Socket是计算机网络通信的基本的技术之一。如今大多数基于网络的软件,如浏览器,即时通讯工具甚至是P2P下载都是基于Socket实现的。本文会介绍一下基于TCP/IP的Socket编程,并且如何写一个客户端/服务器程序。方法/步骤
Java中的socket编程 下面的部分将通过一些示例讲解一下如何使用socket编写客户端和服务器端的程序。 注意:在接下来的示例中,我将使用基于TCP/IP协议的socket编程,因为这个协议远远比UDP/IP使用的要广泛。并且所有的socket相关的类都位于javanet包下,所以在我们进行socket编程时需要引入这个包。
写入数据 接下来就是写入请求数据,我们从客户端的socket对象中得到OutputStream对象,然后写入数据后。很类似文件IO的处理代码。
打开服务器端的socket
读取数据 通过上面得到的socket对象获取InputStream对象,然后安装文件IO一样读取数据即可。这里我们将内容打印出来。
使用socket实现一个回声服务器,就是服务器会将客户端发送过来的数据传回给客户端。打横杠是因为那个方法已经过时了现在已经不怎么用了。。。
Socket 服务器: 1先创建 ServerSocket ss = new ServerSocket(端口号)
2 接收请求 Socket s = ssaccept()
3接收消息 先读后写BufferedReader in = new BufferedReader(
new InputStreamReader(sgetInputStream(),"utf-8"));
String str = inreadLine(); PrintWriter out = new PrintWriter
( new BufferedWriter( new OutputStreamWriter(sgetOutputStream())),true);
outprintln("服务器信息");
4关闭流outclose();
inclose();
isclose();
客户端 1、通过IP地址和端口实例化Socket,请求连接服务器
2、获取Socket上的流以进行读写。
3、对流包装进BufferedReader/PrintWriters实例
4、关闭打开的流
欢迎分享,转载请注明来源:内存溢出
评论列表(0条)