package BaoWen;
|
import java.io.IOException;
|
import java.net.InetAddress;
|
import java.net.UnknownHostException;
|
import java.util.Vector;
|
|
import Method.BaoWenShow;
|
import Method.SaveFIleInTxt;
|
import PbuliClass.ShowMessage;
|
import PbuliClass.Systems;
|
import VectroData.ForwardDatas;
|
import tbDataModel.Tb_forward_data;
|
import tcp.TcpClientOneToMany;
|
import udp_out.udpAndTcpout;
|
import udp_out.udppojo;
|
|
/**¸ÃÀàÓÃÓÚUDPת·¢Êý¾Ýµ½Ö¸¶¨¶Ë¿ÚµØÖ·*/
|
public class Udp_Out {
|
|
|
static boolean savebaowen=Systems.sys().getOpensave().equals("1");
|
static boolean tcp_have_display=ForwardDatas.have_tcp("λÖÃÊý¾Ý");
|
static boolean tcp_have_all=ForwardDatas.have_tcp("È«²¿Êý¾Ý");
|
|
|
|
|
/**ʵÏÖUDPת·¢
|
* @param data ÐèҪת·¢µÄÊý¾Ý
|
* @param length ÐèҪת·¢µÄÊý¾Ý³¤¶È
|
* @param type ÐèҪת·¢µÄÊýÁ¿ÀàÐÍ
|
* @throws IOException */
|
public static void udp_out(byte[] data,int length,String type) {
|
|
Vector<Tb_forward_data> mou_data=ForwardDatas.get_mou_tb_forword("UDP",type);
|
int size=mou_data.size();
|
if( size!=0) {
|
InetAddress address=null;
|
for(int i=0;i<size;i++) {
|
Tb_forward_data fordata=mou_data.get(i);
|
//Èç¹ûÊý¾ÝÀàÐÍÏàͬ
|
try {
|
address=InetAddress.getByName(fordata.getIp());
|
} catch (UnknownHostException e) {
|
e.printStackTrace();
|
}
|
udppojo udppojo=new udppojo();
|
int port=Integer.parseInt(fordata.getPort());
|
udppojo.setData(data);
|
udppojo.setLength(length);
|
udppojo.setIp(address);
|
udppojo.setPort(port);
|
udppojo.setTagid("0000");
|
udppojo.setMessage("0000");
|
udpAndTcpout.getUdppojoVector().add(udppojo);//2023.07.12 zsh
|
}
|
}
|
}
|
|
|
/**½«Êý¾Ýͨ¹ýUDP·¢×ß*/
|
public static void zhuanfa_all_udp_data(byte[] data,int length) {
|
Vector<Tb_forward_data> mou_data=ForwardDatas.get_mou_tb_forword("UDP");
|
int size=mou_data.size();
|
if(size!=0) {
|
|
InetAddress address=null;
|
for(int i=0;i<size;i++) {
|
Tb_forward_data fordata=mou_data.get(i);
|
//Èç¹ûÊý¾ÝÀàÐÍÏàͬ
|
try {
|
address=InetAddress.getByName(fordata.getIp());
|
} catch (UnknownHostException e) {
|
e.printStackTrace();
|
}
|
int port=Integer.parseInt(fordata.getPort());
|
if(port>65535) {
|
ShowMessage.zidingyi(port+"¶Ë¿Ú´íÎó...");
|
return;
|
}
|
udppojo udppojo=new udppojo();
|
udppojo.setData(data);
|
udppojo.setLength(length);
|
udppojo.setIp(address);
|
udppojo.setPort(port);
|
udppojo.setTagid("0000");
|
udppojo.setMessage("0000");
|
udpAndTcpout.getUdppojoVector().add(udppojo);//2023.07.12 zsh
|
}
|
}
|
|
}
|
|
|
|
/**½«Êý¾Ý·¢¸øBS¶Ë*/
|
public static void out(byte[] data,int length,String ip,int port) {
|
|
InetAddress address=null;
|
//Èç¹ûÊý¾ÝÀàÐÍÏàͬ
|
try {
|
address=InetAddress.getByName(ip);
|
} catch (UnknownHostException e) {
|
e.printStackTrace();
|
}
|
udppojo udppojo=new udppojo();
|
udppojo.setData(data);
|
udppojo.setLength(length);
|
udppojo.setIp(address);
|
udppojo.setPort(port);
|
udppojo.setTagid("0000");
|
udppojo.setMessage("0000");
|
udpAndTcpout.getUdppojoVector().add(udppojo);//2023.07.12 zsh
|
}
|
|
|
|
|
|
public static void udpout(int size,Vector<Tb_forward_data> datatype,String message,String tagid) {
|
if(size !=0) {
|
for(int i=0;i<size;i++) {
|
Tb_forward_data fordata=datatype.get(i);
|
if(fordata.getType().equals("UDP")) {
|
InetAddress address=null;
|
try {
|
address=InetAddress.getByName(fordata.getIp());
|
} catch (UnknownHostException e) {
|
ShowMessage.zidingyi("UDPת·¢µØÖ·ÓдíÎó");
|
}
|
int port=Integer.parseInt(fordata.getPort());
|
int length=message.getBytes().length;
|
udppojo udppojo=new udppojo();
|
udppojo.setData(message.getBytes());
|
udppojo.setLength(length);
|
udppojo.setIp(address);
|
udppojo.setPort(port);
|
udppojo.setTagid(tagid);
|
udppojo.setMessage(message);
|
udpAndTcpout.getUdppojoVector().add(udppojo);//2023.07.12 zsh
|
}
|
}
|
}
|
}
|
|
/**UDP»òÕßTCPÊý¾Ýת·¢Î»ÖÃÊý¾Ý*/
|
public static void udp_tcp_out_display(String message,String tagid) {
|
if(ForwardDatas.isUDP()) {//´æÔÚUDPת·¢
|
udpdisplaydata( message,tagid);
|
}
|
if(ForwardDatas.isTCP()) {//´æÔÚTCPת·¢
|
tcpout(message);
|
}
|
}
|
|
|
/**UDP»òÕßTCPÊý¾Ýת·¢GNGGAÊý¾Ý*/
|
public static void GNGGA_udptcp_out(String message,String tagid) {
|
if(ForwardDatas.isUDP()) {//´æÔÚUDPת·¢
|
udp_out_gngga( message,tagid);
|
}
|
if(ForwardDatas.isTCP()) {//´æÔÚTCPת·¢
|
tcpout(message);
|
}
|
}
|
|
/**UDP»òÕßTCPÊý¾Ýת·¢ËùÓÐÊý¾Ý*/
|
public static void alldata_udptcp_out(String message) {
|
if(ForwardDatas.isUDP()) {//´æÔÚUDPת·¢
|
udp_out_all( message,"Ñ¡Ôñ±êÇ©");
|
}
|
if(ForwardDatas.isTCP()) {//´æÔÚTCPת·¢
|
tcpout(message);
|
}
|
}
|
|
|
/**UDPת·¢Î»ÖÃÊý¾Ý»òÕßÈ«²¿Êý¾Ý*/
|
public static void udpdisplaydata(String message,String tagid) {
|
Vector<Tb_forward_data> displaydata=ForwardDatas.getDisplaydata();
|
//Vector<Tb_forward_data> alldata=ForwardDatas.getAlldata();
|
int size1=displaydata.size();
|
udpout(size1,displaydata,message,tagid);
|
/*int size2=alldata.size();
|
udpout(size2,alldata,message,tagid);*/
|
}
|
|
/**UDP»òÕßTCPÊý¾Ýת·¢coustom1Êý¾Ý*/
|
public static void coustom1_udptcp_out(String message,String tagid) {
|
if(ForwardDatas.isUDP()) {//´æÔÚUDPת·¢
|
udp_custom1( message,tagid);
|
}
|
if(ForwardDatas.isTCP()) {//´æÔÚTCPת·¢
|
tcpout(message);
|
}
|
}
|
|
/**UDPת·¢GNGGAÊý¾Ý*/
|
public static void udp_out_gngga(String message,String tagid) {
|
Vector<Tb_forward_data> gnggadata=ForwardDatas.getGnggadta();
|
Vector<Tb_forward_data> alldata=ForwardDatas.getAlldata();
|
int size=gnggadata.size();
|
udpout(size,gnggadata,message,tagid);
|
int size2=alldata.size();
|
udpout(size2,alldata,message,tagid);
|
}
|
|
/**UDPת·¢ËùÓÐÊý¾ÝÊý¾Ý*/
|
public static void udp_out_all(String message,String tagid) {
|
Vector<Tb_forward_data> alldata=ForwardDatas.getAlldata();
|
int size2=alldata.size();
|
udpout(size2,alldata,message,tagid);
|
}
|
|
/**UDPת·¢customÊý¾Ý*/
|
public static void udp_custom1(String message,String tagid) {
|
Vector<Tb_forward_data> custom1data=ForwardDatas.getCustom1data();
|
int size3=custom1data.size();
|
udpout(size3,custom1data,message,tagid);
|
}
|
|
public static void tcpout(String message) {
|
if(tcp_have_display || tcp_have_all ) {
|
TcpClientOneToMany.send(message);
|
BaoWenShow.show(message, "TCPת·¢","Ñ¡Ôñ±êÇ©");
|
if(savebaowen) {
|
SaveFIleInTxt.save_display(message, "Ñ¡Ôñ±êÇ©");
|
}
|
}
|
}
|
|
}
|
