java udp监听_udp服务器监听（多线程）

系统管理员 2022-11-02 11:36 7阅读 0赞

packagecom.ghost.chat.udp;importjava.awt.BorderLayout;importjava.awt.List;importjava.awt.event.ActionEvent;importjava.awt.event.ActionListener;importjava.text.SimpleDateFormat;importjava.util.Date;importjavax.swing.JButton;importjavax.swing.JFrame;importjavax.swing.JLabel;importjavax.swing.JPanel;importjavax.swing.JScrollPane;importjavax.swing.JTextArea;importjavax.swing.JTextField;public class UdpGui extendsJFrame \{/\*\*\*\*/

private static final long serialVersionUID = 1L;private JTextField jtf\_port; //服务器端口(也就是启动监听时服务器开的端口)

private JTextField jtf\_other\_port; //other表示发送给一个电脑：端口为：jtf\_other\_port

private JTextField jtf\_other\_ip; //ip为：jtf\_other\_ip

privateJButton btn\_start;privateJTextArea jta\_message;privateJTextField jtf\_message;privateJButton btn\_send;privateList jl\_list;privateUdpFunc func;private booleanstatus;

UdpGui() \{super("UDP");this.setDefaultCloseOperation(JFrame.EXIT\_ON\_CLOSE);

guiInitialization();

actionInitialization();this.setVisible(true);

\}/\*\*\* 注册事件响应函数\*/

private voidactionInitialization() \{

jtf\_message.setEditable(false);

btn\_send.setEnabled(false);

jl\_list.setVisible(false);

btn\_start.addActionListener(newActionListener() \{public voidactionPerformed(ActionEvent e) \{if (e.getActionCommand().equals("start")) \{int port =Integer.parseInt(jtf\_port.getText());

func= new UdpFunc(port);//服务器端口

status = true;new Thread(newLogic()).start();

postMessage("启动UDP服务器(" + port + ")");

btn\_start.setText("stop");

jtf\_port.setEditable(false);

jtf\_other\_ip.setEditable(false);

jtf\_other\_port.setEditable(false);

jtf\_message.setEditable(true);

btn\_send.setEnabled(true);

\}else if (e.getActionCommand().equals("stop")) \{

status= false;

postMessage("服务器已经停止运行");

btn\_start.setText("start");

jtf\_port.setEditable(true);

jtf\_other\_ip.setEditable(true);

jtf\_other\_port.setEditable(true);

jtf\_message.setText("");

jtf\_message.setEditable(false);

btn\_send.setEnabled(false);

\}else\{

postMessage("发生未注册事件,请验证程序是否被修改");

\});

btn\_send.addActionListener(newActionListener() \{public voidactionPerformed(ActionEvent e) \{if (e.getActionCommand().equals("send")) \{

String message=jtf\_message.getText();if (message.trim().equalsIgnoreCase("")) \{

postMessage("警告:" + "你不能发送空字符串");

\}else\{

func.send(message,

Integer.parseInt(jtf\_other\_port.getText()),//发送给客户机，需指定端口和IP

jtf\_other\_ip.getText());

postMessage("我:" +message);

jtf\_message.setText("");

jtf\_message.requestFocus();

\}else\{

postMessage("发生未注册事件,请验证程序是否被修改");

\});

jtf\_message.addActionListener(newActionListener() \{public voidactionPerformed(ActionEvent e) \{

String message=jtf\_message.getText();if (message.trim().equalsIgnoreCase("")) \{

postMessage("警告:" + "你不能发送空字符串");

\}else\{

func.send(message,

Integer.parseInt(jtf\_other\_port.getText()),

jtf\_other\_ip.getText());

postMessage("自己:" +message);

jtf\_message.setText("");

jtf\_message.requestFocus();

\});

\}/\*\*\* 得到当前系统时间

\*@return当前系统时间\*/String getTime() \{

Date date= newDate();

SimpleDateFormat formater= new SimpleDateFormat("HH:mm:ss");returnformater.format(date);

\}/\*\*\* 向GUI界面递送显示的消息

\*@parammessage

\* 要显示在界面上的消息(会自动加上当前系统时间)\*/

voidpostMessage(String message) \{if (jta\_message.getLineCount() > 500) \{

jta\_message.setText("time:" + getTime() + " " + "消息过多，执行自动清理...\\n");

jta\_message.append("time:" + getTime() + " " + message + "\\n");

jta\_message.requestFocus();

jta\_message.setCaretPosition(jta\_message.getText().length());

\}/\*\*\* 初始化界面\*/

private voidguiInitialization() \{this.setSize(800, 600);this.setLocation(400, 200);this.setResizable(false);

JPanel container= newJPanel();this.add(container);

container.setLayout(newBorderLayout());

JPanel header= newJPanel();

header.add(new JLabel("服务器端口:"));

jtf\_port= new JTextField("5050", 4);

header.add(jtf\_port);

header.add(new JLabel("待发送客户机端口:"));

jtf\_other\_port= new JTextField("5000", 4);

header.add(jtf\_other\_port);

header.add(new JLabel("待发送客户机IP:"));

jtf\_other\_ip= new JTextField("192.168.1.108", 10); //127.0.0.1

header.add(jtf\_other\_ip);

btn\_start= new JButton("start");

header.add(btn\_start);

JPanel main= newJPanel();

jta\_message= newJTextArea();

jta\_message.setAutoscrolls(true);

jta\_message.setEditable(false);

JScrollPane scorllPanel= newJScrollPane(jta\_message);

scorllPanel

.setHorizontalScrollBarPolicy(JScrollPane.HORIZONTAL\_SCROLLBAR\_AS\_NEEDED);

scorllPanel

.setVerticalScrollBarPolicy(JScrollPane.VERTICAL\_SCROLLBAR\_AS\_NEEDED);

main.setLayout(newBorderLayout());

main.add(scorllPanel, BorderLayout.CENTER);

JPanel bottom= newJPanel();

jtf\_message= new JTextField("", 25);

btn\_send= new JButton("send");

bottom.add(new JLabel("Send:"));

bottom.add(jtf\_message);

bottom.add(btn\_send);

JPanel right= newJPanel();

right.setLayout(newBorderLayout());

jl\_list= newList();

right.add(jl\_list, BorderLayout.CENTER);

container.add(header, BorderLayout.NORTH);

container.add(main, BorderLayout.CENTER);

container.add(bottom, BorderLayout.SOUTH);

container.add(right, BorderLayout.EAST);

\}/\*\*\* 逻辑类，主要负责接收报文并显示出来

\*@authorghost

\*\*/

private class Logic implementsRunnable \{public voidrun() \{while (status) \{//true

String message =func.read();

System.out.println(message);

postMessage("对方：" +message);

\}/\*\*\*@paramargs\*/

public static voidmain(String\[\] args) \{//TODO Auto-generated method stub

newUdpGui();

java udp监听_udp服务器监听（多线程）

发表评论取消回复

还没有评论，来说两句吧...

相关阅读

相关 java实现UDP多线程咨询

相关工作随笔——rabbitmq的多线程监听（Springboot）

相关【Java】网络编程UDP 实现多线程在线聊天

相关 TCP和UDP可以同时监听相同的端口吗

相关 Swoole-UDP服务器

相关 java udp监听_udp服务器监听（多线程）

相关 android线程不断监听,Android 如何监听一个线程的开始和结束

相关 Nginx监听ipv6 的udp端口

相关 UDP监听

相关 python多线程实现UDP网络通信代码演示