TCP和UDP中怎么加入多线程、多进程?

TCP和UDP中怎么加入多线程、多进程?,第1张

1、UDP

UDP(User Datagram Protocol,用户数据报协议)不提供复杂的控制机制,利用IP提供面向无连接的通信服务。它是将应用程序发来的数据在收到的那一刻,立即按照原样发送到网络上的一种机制。

UDP的特点

UDP是一个非连接的协议,传输数据之前,源端和终端不建立连接,当它想传送时就简单地去抓取来自应用程序的数据,并尽可能快地把它扔到网络上。在发送端,UDP传送数据的速度仅仅是受应用程序生成数据的速度、计算机的能力和传输带宽的限制;在接收端,UDP把每个消息段放在队列中,应用程序每次从队列中读一个消息段;由于传输数据不建立连接,因此也就不需要维护连接状态,包括收发状态等,因此一台服务机可同时向多个客户机传输相同的消息;UDP信息包的标题很短,只有8个字节,相对于TCP的20个字节信息包的额外开销很小;UDP使用尽最大努力交付,即不保证可靠交付,因此主机不需要维持复杂的链接状态表(有许多参数);UDP是面向报文的。发送方的UDP对应用程序交下来的报文,在添加首部后就向下交付给IP层。既不拆分,也不合并,而是保留这些报文的边界,因此,应用程序需要选择合适的报文大小。

2、TCP

TCP(Transmission Control Protocol,传输控制协议)是面向连接的协议,也可是说是对“传输、发送、通信”进行“控制”的协议。

TCP作为一种面向有连接的协议,只有在确认通信对端存在时才会发送数据,从而可以控制通信流量的浪费。且TCP实现了数据传输时各种控制功能,可以进行丢包时的重发控制,还可以对次序乱掉的分包进行顺序控制。TCP通过检验和、序列号、确认应答、重发控制、连接管理以及窗口控制等机制实现可靠性传输。

TCP与UDP的区别

TCP面向连接(如打电话要先拨号建立连接)。UDP是无连接的,即发送数据之前不需要建立连接;TCP提供可靠的服务。也就是说,通过TCP连接传送的数据,无差错,不丢失,不重复,且按序到达。UDP尽最大努力交付,即不保证可靠交付;TCP面向字节流,实际上是TCP把数据看成一连串无结构的字节流。UDP是面向报文的;每一条TCP连接只能是点到点的。UDP支持一对一、一对多、多对一和多对多的交互通信;对系统资源的要求TCP较多,UDP少。TCP首部开销20字节,UDP的首部开销小,只有8个字节;TCP的逻辑通信信道是全双工的可靠信道。UDP则是不可靠信道。

TCP建立连接的3次握手过程

主机A通过向主机B发送一个含有同步序列号的标志位的数据段给主机B,向主机B请求建立连接,通过这个数据段,主机A告诉主机B两件事:我想要和你通信;你可以用哪个序列号作为起始数据段来回应我;主机B收到主机A的请求后,用一个带有确认应答(ACK)和同步序列号(SYN)标志位的数据段响应主机A,也告诉主机A两件事:我已经收到你的请求了,你可以传输数据了;你要用哪个序列号作为起始数据段来回应我;主机A收到这个数据段后,再发送一个确认应答,确认已收到主机B的数据段:“我已收到回复,我现在要开始传输实际数据了”。

这样3次握手就完成了,主机A和主机B就可以传输数据了。

TCP断开连接的4次确认

当主机A完成数据传输后,将控制位FIN置1,提出停止TCP连接的请求;主机B收到FIN后对其作出响应,确认这一方向上的TCP连接将关闭,将ACK置1;由B端再提出反方向的关闭请求,将FIN置1;主机A对主机B的请求进行确认,将ACK置1,双方向的关闭结束。

由TCP的3次握手和4次断开确认可以看出,TCP使用面向连接的通信方式,大大提高了数据通信的可靠性,使发送数据端和接收端在数据正式传输前就有了交互,为数据正式传输打下了可靠的基础。

我们经常使用“ping”命令来测试两台主机之间TCP/IP通信是否正常,其实“ping”命令的原理就是向对方主机发送UDP数据包,然后对方主机确认收到数据包,如果数据包是否到达的消息及时反馈回来,那么网络就是通的。

QT线程是独立的类:

在QT中添加C++类,头文件引用#include <QThread>类公开,这样写:

class XXXX:public QThread,类里面申明Q_OBJECT,直接写在里面。signals: XXX()这是你的订阅事件名。private:void run()这是run函数;public: int cona=3这是变量,一定要public。

cpp文件里引用头文件,run函数里面写方法:

void XXXX::run()

{

do

{

msleep(cona)

emit connec()

}while(true)

}

上面就是线程类了。现在我们在窗体中应用,先在头文件申明

头文件private: XXXX *thread1XXXX *thread2

构造函数中初始化他们

thread1=new XXXX()

thread1->cona=3

QObject::connect(thread1,SIGNAL(connec()),this,SLOT(XXX信号1()))

thread2=new XXXX()

thread2->cona=4

QObject::connect(thread2,SIGNAL(connec()),this,SLOT(XXX信号2()))

XXX信号1()是读A数据,XXX信号2()读B数据。

按钮1的信号槽里写方法同时进行每3秒读A、没4秒读B

thread1->start()

thread2->start()

要结束谁就用 xxxx->terminate()

看明白没?QT可不同与C++,你不熟悉编程环境,是很难理解的。

Spring aop 依赖注入的就是单例对象,我们在使用的时候如果有多个相同处理且不怎么耗时的情况下一般会采用for循环直接执行,这样的情况下即使有事务管理也不会影响业务执行下去;但是,大多数的应用比如:系统与系统之间的交互就比较耗时了,此时使用for循环执行业务就不可取了,于是我们想用线程来解决这个问题。

另外,附带说明一下:如果是在Spring提供的@Test下测试:如果有多线程处理,需要调用Thread.sleep(3000)实现线程等待,这也是测试多线程模式下所必须的。如果不加线程休眠,不等待多线程执行完毕,很有可能测不出来多线程调用的处理。


欢迎分享,转载请注明来源:内存溢出

原文地址: https://outofmemory.cn/bake/11820892.html

(0)
打赏 微信扫一扫 微信扫一扫 支付宝扫一扫 支付宝扫一扫
上一篇 2023-05-18
下一篇 2023-05-18

发表评论

登录后才能评论

评论列表(0条)

保存