别人用UDP进行数据传输,我只需监听端口进行数据接收,需要用到消息中间件吗。

用到消息中间件的话,是不是只用消费的模块,但是这样要怎么把数据先存到消息队列里呢。还是我自己拿到数据后,自己当producer把数据再放到消息队列,然后再按顺序消费。

0

1个回答

一般做法是将网络数据接收和数据处理拆开,网络处理部分只关注编解码,将解码之后的数据投递到message queue中,然后在搞一个项目消费消息队列中的数据

0
Csdn user default icon
上传中...
上传图片
插入图片
抄袭、复制答案,以达到刷声望分或其他目的的行为,在CSDN问答是严格禁止的,一经发现立刻封号。是时候展现真正的技术了!
其他相关推荐
udp的socket数据传输
关于socket的配置:         1、创建sokcet套接字 2、为创建的socket绑定地址与端口,指定传输的协议(SOCK_STREAM、SOCK_DGRAM)         3、打开文件标识符,并开始发送数据 udp客户端CODE: #include #include #include #include #include #include #include
使用UDP协议编写一个网络程序,设置接收端程序监听端口为8001,发送端发送的数据是“hello world”
21、使用UDP协议编写一个网络程序,设置接收端程序监听端口为8001,发送端发送的数据是“hello world”。 提示: 1)使用new DatagramSocket(8001)构造方法创建接收端的DatagramSocket对象,调用receive()方法接收数据。 2)发送端和接收端使用DatagramPacket封装数据,在创建发送端的DatagramPacket对象时需要指定目
UDP客户端实现在不同端口上发送和接收数据
普通udp通信,客户端在发送完数据后,只需要在相同socket上,recvfrom即可 服务端给的回应,可以是同一端口,也可以是不同端口,客户端在接收时,需要指点一个本地端口进行接收,此端口也可以用bind和创建的socket绑定。 但是bind必须是在通过这个socket发送数据前绑定,在发送数据后再bind会失败。 下面给出代码: #define SEND_PORT 8000
c# socket监听UDP数据
改代码可以接受监听到局域网中的UDP数据包,端口号随使用者改变
udp 传输数据
udp 传输 在tcp传输后,如果需要传输大量的数据那就需要使用udp协议,使用的数据报格式 即 SOCK_DGRAM 的udp 编程模型 服务器端步骤 第一步: 创建一个socket 套接口,返回一个文件描述符 第二步: 通过bind 绑定socket 本地的IP地址还有端口号 第三步: 直接用recvfrom从套接口接收客户端发送过来的数据 包含客户端的IP地址和端口号,如果没...
UDP协议数据传输
UDP数据传输就像,两台电脑就像两个码头(Socket)一样,码头上有集装箱货物和船只运输货物到另一个码头。码头xian相当于Socket,装货物的集装箱相当于需要发送的数据,运输的船只就是IO流了。图示如下:    思路大致如上,实现代码如下: 1.UDP_Recv.java public class UDP_Recv {     public static void mai...
同一端口监听tcp和udp请求
问题:众所周知,同一台机器的同一个端口只可以被一个进程使用。一个进程使用同一个端口同时监听tcp、udp请求,是否可以呢?答案:是可以的。代码:server为了同时监听,server使用select进行多路访问控制。 server端代码如下:/* TCP INET use select */#include<stdio.h> #include<stdlib.h> #include<string.h
关于epoll 水平触发在udp套接字上不生效问题的原因
背景简介: epoll有两个模式可以设置,一个是水平模式(level-triggered),另一个是边缘模式(edge-triggered), 区别就是水平模式可以带来事件的重复触发,而边缘模式只触发一次。举个栗子,当epoll监听的描述符发生可读事件时,比方说收到了别人发来的数据,...
UDP用同一端口收发数据 c#
之前用UdpClient,发现当开了一个端口用于监听接收,则不能再用来发送(反之亦然)。这样对于简单的收发信息来说无问题,但如果需要nat穿透的程序,则变得困难。用Socket类则不存在该问题,参考下面示例代码:     class Program    {        static void Main(string[] args)        {            SocketT...
用UDP进行广播后绑定发送Json数据进行通讯
用UDP通讯,要绑定服务器的IP以及端口号,同样服务器也要知道它的信息要发给谁,所以客户端要将自己的IP以及端口号发送给服务器,以便服务器直接发送数据到该客户端。 我遇到的问题: 1.服务器接收到信息后,发送信息,客户端接收不到,用抓包工具进行检测的时候,发现客户端的端口号一直在更改。 端口号不断更改是正常的。服务器只需要处理只要是从该客户端IP发从过来的信息就可以,不用
TCP UDP多机通信无法接收到数据的问题
TCP UDP调试注意事项 一般如果是使用localhost和127.0.0.1这种做server端IP的情况,服务器与客户一般是在一个主机上进行了,这个时候做调试一般不会出现什么问题。但是不同的机器做主机与服务器的时候就不一样了。比方说Android与电脑,电脑与电脑通信会出现各种奇怪的问题。出现这种问题一般可以从以下几种途径找问题: (1)电脑上是不是开了防火墙,如果开了就关掉 (2)电
查看某端口是否有数据发出、是否有数据发往某端口
查看是否有数据从某端口发出 LINUX&WIN:    telnet 10.100.20.137 7780 #查看10.100.20.137服务器的7780是否有数据发出 WIN,另外的方法:   winshark 查看是否有数据发往某端口 LINUX:    tcpdump udp port 11011 #是否有数据走UD
Android手机发送和监听UDP数据
UDP协议中文名是用户数据报协议,在网络中它与TCP协议一样用于处理数据包,是一种无连接的协议。在OSI模型中,在第四层——传输层,处于IP协议的上一层。与所熟知的TCP(传输控制协议)协议一样,UDP协议直接位于IP(网际协议)协议的顶层。根据OSI(开放系统互连)参考模型,UDP和TCP都属于传输层协议。UDP协议的主要作用是将网络数据流量压缩成数据包的形式。一个典型的数据包就是一个二进制数据
C#使用socket发送和接受数据
C#使用socket发送和接受数据,一看就懂~~~非常适合新手!
python的多线程udp使用(简陋的自由聊天器)
udp可以通过多线程来实现两机之间的 ‘’类似’‘ qq一样 ‘’自由‘’ 聊天功能,不再是死板的要么只接收数据,要么只发送数据。 import socket #引入套接字 import threading #引入并行 def udp_send(udp_socket): while True: num1 = '192.168.232.1' ...
TCP和UDP可以监听同一个端口
同时监听的意思是同一时刻让tcp的某一端口和udp的同一数值的端口同时处于listening状态。 有的网友说udp的不能叫监听,应该有个其他的叫法。我认为都可以,只要把意思表达出来即可。 tcp监听办法: SOCKET sock = socket(TCP) sockaddr_in sin sin.port = htons(xxx) bind(sock,...
监听UDP端口
说明问题 如果我们要监控TCP协议的端口,那么比较简单。只要通过 telnet ip port,就可以查看端口是否处于正常状态。因为TCP的协议是应答式的,也就是说,从发请请求到结束,TCP会跟踪最后的结果是怎样,这个对于重要信息的发送是较为重要的。但是,如果要我们去监听UDP的端口,那就麻烦了,我们不能用telnet的命令,当然网站上也给出了一些在linux和windows上分别使用的命令去pi...
UDP传输:(四)通过多线程改进,在一个窗口中同时接收又发送
UDP传输:(四)通过多线程改进,在一个窗口中同时接收又发送
C# 中UDP通信时 发送数据并需要事先Bind IP地址
C#中进行UDP通信时,在发送数据的时候,如果不事先Bind一个IP地址,就会随机分配一个地址进行发送数据。发送端class Program { static Socket client; static void Main(string[] args) { client = new Socket(AddressFamil
C# UDP接收不同端口的数据报文
在unity中使用UDP进行数据的交互,建立C/S模式,两个客户端和一个服务端。两个客户端使用不同的端口往服务端发送数据,服务端根据收到的数据进行处理和判断,控制服务端的显示。 说明:两个客户端连接的是Kinect V2,需要将检测到的人体的数据信息发送到服务端进行系统数据的整体显示。指定的消息协议是ClientID|index|PosLeft|Left_S|PosRight|Right_S|A
Udp同一个socket接收与发送实现
1、一个socket实现udp收发socket用于udp通信时,是不区分Server与Client的。因为是无连接的,发送完了也就完了。同样接收到数据也就完成了一次通信。因此,Server端与Client端的措辞在Udp通信中的含义其实就退化了。将socket用于tcp编程时,都比较喜欢send和recv函数。而用于udp通信编程时,个人感觉用sendto和recvfrom更方便。因为socket用
udp使用同一个套接字进行收发数据(三)
udp使用同一个套接字进行收发数据 报一下环境: win10 + pycharm(python3.7)+ mNetAssist import socket def main(): # 1.创建一个套接字 udp_socket = socket.socket(socket.AF_INET, socket.SOCK_DGRAM) # 2.发送数据 # 2.1获取对...
udp server接收数据并发送数据
需求:    .编写一个sever接收udp广播,如果有数据接收,就回应自己mac地址;(也可添加条件发送)    .编写client用于测试;/*****     server    *********//*------------------------------------------------------------------ -   Filename      :   MyBroa...
使用多线程实现UDP进行数据的收发
本次虽只有代码部分,但理解起来不会有困难 需要的知识点:1.UDP的基本使用   2,多线程的使用 代码如下: import socket import threading def send(udp_socket,send_ip,send_port): #要发送的数据 send_data = input(&quot;请输入要发送的数据&quot;) udp_socket.sendt...
Android手机实现同一端口发送和接收UDP数据
有时候Android手机发送UDP消息,需要知道有没有发送成功,这就要监听反馈回来的消息。一般情况下,反馈的消息发送到的是手机发送端口,所以这时候发送端口和接收端口是同一个端口。在我的第一篇文章中(http://blog.csdn.net/u012833261/article/details/78982538),使用的就是DatagramSocket,这在启动监听线程时占用发送端口,造成无法同时接
flume网络端口 收集数据
1、在$FLUME_HOME/agentconf 目录下创建一个数据采集方案,该方案就是从一个网络端口收集数据,也就是创一个任意命名的配置文件如下:netcat-logger.properties文件内容如下:# 定义这个 agent 中各个组件的名字a1.sources = r1a1.sinks = k1a1.channels = c1# 描述和配置 source 组件:r1a1.sources...
TCP UDP 数据传输测试工具
1、支持TCP、UDP传输测试工具 2、支持服务端和客户端同时监听
同一端口监听TCP与UDP数据包
展示了关于udp与tcp在同一端口下的监听实现。
三十九、Udp网络1:使用socket 发送、接收数据,绑定端口和中文编码解码问题
一、初识Udp网络发送数据 (1)前提:必须要保证他们在同一个局域网中,要在一个网段才行         NetAssist.ext软件是用来协助我们完成网络请求:         网络设置:填写的是自己电脑上的IP地址。         目标主机和目标端口:填写的是你要给谁发送的那个人的ip地址和端口号。         发送的内容:在那个大白框中进行填写。     1、网络调试助手...
Java使用udp传输方式进行网络通信
java使用udp协议进行网络通信
很实用的端口接收数据并存储到数据库中的程序
通过11000端口接收数据,然后进行解析插入到数据库中。
MATLAB下UDP通信的简单实现
MATLAB下UDP通信实践 UDP是面向无连接的通信协议,使用简单,但是安全性不足,这里利用MATLAB实现本地主机的UDP通信,与远程主机的相类似,只不过更改一下地址而已。 代码如下,写入文件即可: u1=udp('222.20.36.185','RemotePort',8866,'LocalPort',8844);%与IP为222.20.36.185的远程主机(其实是我自己的IP)建立...
Linux C语言下UDP实现指定端口收发数据实例
Linux C语言下UDP实现指定端口收发数据实例
Java udp协议进行传输数据
Java中对使用UDP协议进行传输的数据,使用DategramSocket和DatagramPacket两个类来进行处理,其实挺简单的,在这里进行一个学习之后的总结。 发送端的代码: public class Send { public static void main(String[] args) throws IOException { DatagramSoc
Unity3D笔记——UDP 广播和异步接受
前言:Unity3D笔记是我平时做一些好玩的测试和研究,记录的笔记。会比较详细也可能随口一提就过了。 所以大家见谅了,内容一般都会是原创的(非原创我会注明转载)。由于很多内容其他的朋友也肯定研究发表过,大家用于指出错误。前段时间,公司有一个针对游乐园的项目。项目是基于安卓3399板子的,会检测一些红外的触碰来替代鼠标当作输入。本来以为那么就 Launcher 里有个服务,检测到有触碰那么转换下屏幕坐
Flume实战监听网络端口
具体的配置解释见官网 http://flume.apache.org/FlumeUserGuide.html#flume-sources 1、flume安装目录下新建文件夹 example  2、在example下新建文件  netcat-logger.conf 内容如下: #name the components on this agent a1.sources = r1
Android UDP 监听数据包
本文版权归作者所有,欢迎转载,但未经作者同意必须保留此段声明,且在文章页面明显位置给出原文连接,否则保留追究法律责任的权利。
Java使用UDP协议收发数据简单实现
UDP简介1.UDP 是User Datagram Protocol的简称, 中文名是用户数据报协议!简单Java代码实现!适合初学!
UE4_UDPSocket进行不同工程的数据交互
以下内容仅对此次工程做解析。UE4.15.1 VS2015实现效果:客户端与服务器端的socket连接之后。 客户端设定一个timer去发送消息 服务端每个timer去检查是否接受到了消息,如果接收到了就讲消息打印原理解析:想要实现不同工程下的通讯。需要在同一个局域网内(外网还未测)。两个工程需要一个为客户端一个为服务端。在这里实现的是一个客户端发送数据而服务端接收数据。实现步骤: 客户端:1.创
【三】Flume的使用:从指定的网络端口采集数据输出到控制台
官网介绍官网配置介绍agent配置文件:# example.conf: A single-node Flume configuration# Name the components on this agent# a1是agent的名称# r1是source的名称# k1是sink的名称# c1是channel的名称a1.sources = r1a1.sinks = k1a1.channels = ...