「javaudp包」javaudp通信
本篇文章给大家谈谈javaudp包,以及javaudp通信对应的知识点,希望对各位有所帮助,不要忘了收藏本站喔。
本文目录一览:
- 1、java怎么实现JSON打包UDP
- 2、java中如何判断udp报文的完整性
- 3、JAVA中如何完成UDP包的封装
- 4、JAVA用udp从本地网络穿透到公网之后,从其他网络作为客户端发送udp包到服务器正常接收。
- 5、用Java编写简单的UDP网络通信程序
java怎么实现JSON打包UDP
java实现JSON打包UDP cJSON支持在C程序中创建和解析JSON数据,其提供多种方法供C程序使用,最直接的是将cJSON.c和cJSON.h加入到C工程中
(1) QJsonObject用于在Qt中创建JSON对象
(2)数据传输通过UDP运行
代码如下
首先在pro文件中加入
QT += network
h文件内容:
首先在pro文件中加入
QT += network
h文件内容:
#ifndef MAINWINDOW_H
#define MAINWINDOW_H
#include QMainWindow
#includeQtNetwork
namespace Ui {
class MainWindow;
}
class MainWindow : public QMainWindow
{
Q_OBJECT
public:
explicit MainWindow(QWidget *parent = 0);
~MainWindow();
QUdpSocket *sender;
QByteArray byteArray;
private slots:
void on_pushButton_clicked();
private:
Ui::MainWindow *ui;
};
#endif // MAINWINDOW_H
cpp文件内容:
#include "mainwindow.h"
#include "ui_mainwindow.h"
#includeQJsonObject
#includeQJsonDocument
#includeQDebug
MainWindow::MainWindow(QWidget *parent) :
QMainWindow(parent),
ui(new Ui::MainWindow)
{
ui-setupUi(this);
sender = new QUdpSocket(this);
QJsonObject rectJson;
rectJson.insert("Type","Rectangle");
rectJson.insert("height",42);
rectJson.insert("widght",23);
QJsonDocument rectJsonDoc;
rectJsonDoc.setObject(rectJson);
byteArray = rectJsonDoc.toJson(QJsonDocument::Compact);
}
MainWindow::~MainWindow()
{
delete ui;
}
void MainWindow::on_pushButton_clicked()
{
QHostAddress address;
address.setAddress(QString("192.168.230.140"));
sender-writeDatagram(byteArray.data(),byteArray.size(),
address,4444);
}
程序通过端口4444,向IP为192.168.230.140的主机发送JSON数据
C程序如下:
{
int sock_fd;
char rcv_buff[512];
struct sockaddr_in client_addr;
struct sockaddr_in server_addr;
int client_len;
int rcv_num = -1;
if ((sock_fd = socket(AF_INET, SOCK_DGRAM,0)) 0)
{
perror("socket create error\n");
exit(1);
}
memset(server_addr,0,sizeof(struct sockaddr_in));
server_addr.sin_family = AF_INET;
server_addr.sin_port = htons(4444);
server_addr.sin_addr.s_addr = htonl(INADDR_ANY);
client_len = sizeof(struct sockaddr_in);
if (bind(sock_fd, (struct sockaddr *)server_addr, sizeof(struct sockaddr_in)) 0)
{
perror("bind socket error.\n");
exit(1);
}
while (1)
{
/*zero the buff of rvbsm and hvbsm? zhp*/
rcv_num= recvfrom(sock_fd, rcv_buff, sizeof(rcv_buff), 0, (struct sockaddr*)client_addr, client_len);
if (rcv_num0)
{
rcv_buff[rcv_num] = '\0';
printf("rx bsm num = %d\n",rcv_num);
//printf();
printf("%s %u says: %s\n",inet_ntoa(client_addr.sin_addr),ntohs(client_addr.sin_port),rcv_buff);
//parse_UDP_data(rcv_num,rcv_buff);
if(rcv_buff != NULL)
{
cJSON* pJson = cJSON_Parse(rcv_buff);
if(pJson == NULL)
{
printf("Json Parse failed.\n");
return 0;
}
cJSON* pSub1 = cJSON_GetObjectItem(pJson,"Type");
cJSON* pSub2 = cJSON_GetObjectItem(pJson,"height");
cJSON* pSub3 = cJSON_GetObjectItem(pJson,"widght");
if(pSub1!=NULL)
{
printf("Type : %s\n", pSub1-valuestring);
}
if(pSub2!=NULL)
{
printf("height : %d\n", pSub2-valueint);
}
if(pSub3!=NULL)
{
printf("widght : %d\n", pSub3-valueint);
}
}
}
else
{
perror("recv BSM error\n");
break;
}
}
close(sock_fd);
}
编译C程序:gcc -I. -lm -o rencode *.c
由于cJSON使用了标准数学库,所以在编译中需链接其库文件-lm;
在IP为192.168.230.140的Linux服务器中执行./rencode
输出结果为:
java中如何判断udp报文的完整性
UDP报文的完整性,不是JAVA语言本身能够保证的,主要还是靠网络通信协议。一般来说1500个字节应该不会出现在网络中只传输一部分过来的情况,因为1500个字节还在一个UDP包的范围内,因此会一次性发送的。但是,根据经验,超过1K的udp报文,丢包率通常是比较高的。当然,局域网环境下这个丢包率会小很多。
另外还有一个问题,你的消息接收的缓冲区要足够大,如果你的缓冲区只有1000个字节的话,那么100%你收不到一个完整的包。所以,设置合理的缓冲区也是必要的。
JAVA中如何完成UDP包的封装
给你一段代码,或许可以帮到你……
public class SendSideTest {
/*发送数据 */
public static void main(String[] args) throws IOException {
//1 DatagramSocket是用来接收发送数据的
DatagramSocket ds = new DatagramSocket();
//2 发送什么
byte[] s="helloabcdef".getBytes();
//3 发送到哪,发送到本机
InetAddress clientAddress=InetAddress.getLocalHost();
//4 搭建一个outDataPacket相当于一个邮包
//把发送的内容,发送的地址,发送的端口,写在邮包上
DatagramPacket op = null;
op=new DatagramPacket(s, s.length,clientAddress, 9999);
//5 通过一个DatagramPacket将数据发送到客户端,
//客户端的地址由DatagramPacket指定,即写在邮包上
ds.send(op);
System.out.println("数据已经成功发送");
}
}
public class ReceiveSideTest {
/* 接收方*/
public static void main(String[] args) throws IOException {
//1 DatagramSocket相当于建立一个服务器 在9999监听
DatagramSocket ds = new DatagramSocket(9999);
//2 DatagramPacket是用来接收发送的数据的 要有容器接收
byte[] msg = new byte[100];
DatagramPacket ip = new DatagramPacket(msg, msg.length);
//3调用receive方法接收数据到DatagramPacket 中
//数据又由DatagramPacket放入msg
ds.receive(ip);
String msgs = new String(msg);
System.out.println(msgs);
//4通过DatagramPacket得到地址和端口 把发送者打印出来
InetAddress clientAddress = ip.getAddress();
int clientPort = ip.getPort();
System.out.println("发送者:"+clientAddress);
System.out.println("发送端口:"+clientPort);
}
}
JAVA用udp从本地网络穿透到公网之后,从其他网络作为客户端发送udp包到服务器正常接收。
你说的还不清楚。Java网络编程使用Socket,同为一个网络下的主机时是肯定没问题的,不论同一局域网或广域网。如果内网跨越网关,我没做过试验,按我的理解,内网主机做客户端,独立主机做服务器应该可行,反之不行。
用Java编写简单的UDP网络通信程序
Java中封装了大量的socket API 为编写网络通信程序提供了极大的方便 在计算机网络的学习中 大家都已熟练掌握了TCP/UDP的基本原理 在此不在赘述 仅给出接收端和发送端的源代码 供大家讨论学习 发送端代码如下:import java io *;import java lang *;import *;public class uclient{private DatagramSocket cli;private DatagramPacket pac;private byte *** [];private String sen;public uclient(){Init();}public void Init(){try{//指定端口号 避免与其他应用程序发生冲突cli=new DatagramSocket( ); *** =new byte[ ];sen= UDP方式发送数据 ; *** =sen getBytes();pac=new DatagramPacket( *** *** length InetAddress getByName( localhost ) );cli send(pac);}catch(SocketException se){se printStackTrace();}catch(IOException ie){ie printStackTrace();}}public static void main(String args[]){new uclient();}}接收端数据:import java io *;import java lang *;import *;public class userve{private DatagramSocket ser;private DatagramPacket pac;private byte rb[];private String rev;public userve(){Init();}public void Init(){try{ser=new DatagramSocket( );rb=new byte[ ];pac=new DatagramPacket(rb rb length);rev= ;int i= ;while(i== )//无数据 则循环{ser receive(pac);i=pac getLength();//接收数据if(i ){//指定接收到数据的长度 可使接收数据正常显示 开始时很容易忽略这一点rev=new String(rb pac getLength());System out println(rev);i= ;//循环接收}}}catch(Exception e){e printStackTrace();}}public static void main(String args[]){new userve();}} lishixinzhi/Article/program/Java/hx/201311/26023
javaudp包的介绍就聊到这里吧,感谢你花时间阅读本站内容,更多关于javaudp通信、javaudp包的信息别忘了在本站进行查找喔。