码迷,mamicode.com
首页 > 编程语言 > 详细

Java系列讲座二:Socket网络通信实现聊天软件项目讲解(UDP)

时间:2017-07-14 10:15:55      阅读:238      评论:0      收藏:0      [点我收藏+]

标签:tcp   网络通信   udp   socket   

    上一篇我们讲了通过TCP方式实现网络通信软件开发的原理,思路及实现,今天跟大家谈谈Socket通信中UDP方式通信的软件开发步骤及主要代码讲解,UDP实现方式实现的通信软件特点是不分客户端与服务器端,一个程序既是客户端与是服务器端,典型软件是一些局域网的聊天软件,如飞鸽等软件。

    UDP方式通信主要用到了java.net包中的3个类分别是DatagramPacket类,DatagramSocket类与InetAddress类,下面通过实现一个简易聊天软件小项目来讲解他们的使用方法,代码如下:

package T16;


import java.awt.BorderLayout;

import java.awt.Color;

import java.awt.FlowLayout;

import java.awt.GridLayout;

import java.awt.event.ActionEvent;

import java.awt.event.ActionListener;

import java.io.IOException;

import java.net.DatagramPacket;

import java.net.DatagramSocket;

import java.net.InetAddress;

import java.net.SocketException;

import java.net.UnknownHostException;

import java.util.Date;


import javax.swing.BorderFactory;

import javax.swing.JButton;

import javax.swing.JEditorPane;

import javax.swing.JFrame;

import javax.swing.JLabel;

import javax.swing.JOptionPane;

import javax.swing.JPanel;

import javax.swing.JTextField;

/**

 * UDP通信的聊天软件

 * 

 * */

public class UDPChat extends JFrame implements ActionListener{


private JLabel lblPort,lblAddr,lblPort2;

private JTextField txtPort,txtAddr,txtPort2;

private JButton btnConn,btnSend,btnClose;

private JEditorPane txtReceive,txtSend;

public UDPChat(int n){

}

private UDPChat(int n,int m){

}

public UDPChat() {

super("UDP通信的聊天软件");

lblPort = new JLabel("本机端口:",JLabel.RIGHT);

lblPort2 = new JLabel("对方端口:",JLabel.RIGHT);

lblAddr = new JLabel("对方地址:",JLabel.RIGHT);

txtPort = new JTextField("8888",5);

txtPort2 = new JTextField("9999",5);

InetAddress ipaddr =null;

try {

ipaddr = InetAddress.getLocalHost();

} catch (UnknownHostException e) {

e.printStackTrace();

}

txtAddr = new JTextField(ipaddr.getHostAddress(),10);

btnConn = new JButton("连接(C))");

btnConn.setMnemonic(‘C‘);

JPanel topPanel = new JPanel(new FlowLayout(FlowLayout.LEFT));

topPanel.add(lblPort);

topPanel.add(txtPort);

topPanel.add(lblAddr);

topPanel.add(txtAddr);

topPanel.add(lblPort2);

topPanel.add(txtPort2);

topPanel.add(btnConn);

txtReceive = new JEditorPane();

txtSend = new JEditorPane();

JPanel centerPanel = new JPanel(new GridLayout(2,1,5,10));

centerPanel.add(txtReceive);

txtReceive.setBorder(BorderFactory.createLoweredBevelBorder());

//接收框不能编辑

txtReceive.setEditable(false);

txtSend.setBorder(BorderFactory.createLoweredBevelBorder());

centerPanel.add(txtSend);

btnSend = new JButton("发送(S)");

btnSend.setMnemonic(‘S‘);

btnClose = new JButton("退出(X)");

btnClose.setMnemonic(‘X‘);

JPanel bottomPanel = new JPanel(new FlowLayout(FlowLayout.RIGHT));

bottomPanel.add(btnSend);

bottomPanel.add(btnClose);

add(topPanel,BorderLayout.NORTH);

// centerPanel.setBackground(Color.RED);

add(centerPanel,BorderLayout.CENTER);

add(bottomPanel,BorderLayout.SOUTH);

btnConn.addActionListener(this);

btnSend.addActionListener(this);

btnClose.addActionListener(this);

//发送按钮禁用

btnSend.setEnabled(false);

setSize(600, 400);

setVisible(true);

setLocationRelativeTo(null);

setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);

}


//创建内部类,实现接收线程

class ReceiveThread extends Thread{

DatagramSocket socket;

public ReceiveThread() {

try{

int port = Integer.parseInt(txtPort.getText().trim());

socket = new DatagramSocket(port);

}catch(Exception e){

e.printStackTrace();

}

}

@Override

public void run() {

byte[] b = new byte[1024];

DatagramPacket packet = new DatagramPacket(b,b.length);

while(true){

try {

//接收数据

socket.receive(packet);

//转换为字符串

String str = new String(b,0,packet.getLength());

//显示在接收框

String content = txtReceive.getText();

content += new Date().toLocaleString()+"\n";

content += str+"\n";

txtReceive.setText(content);

} catch (IOException e) {

e.printStackTrace();

}

}

}

}

public static void main(String[] args) {

// UDPChat chat = new UDPChat();

try {

Class.forName("T16.UDPChat").newInstance();

} catch (InstantiationException e) {

e.printStackTrace();

} catch (IllegalAccessException e) {

e.printStackTrace();

} catch (ClassNotFoundException e) {

e.printStackTrace();

}

}


@Override

public void actionPerformed(ActionEvent e) {

if(e.getSource()==btnConn){

btnConn.setEnabled(false);

btnSend.setEnabled(true);

//启动线程

new ReceiveThread().start();

}else if(e.getSource()==btnSend){

//发送内容

String str = txtSend.getText().trim();

if(str.equals("")){

JOptionPane.showMessageDialog(this, "请输入要发送的内容");

return;

}

//把要发送的内容显示到接收框

String content = txtReceive.getText();

content += new Date().toLocaleString()+"\n";

content += str+"\n";

txtReceive.setText(content);

try {

//设置对方IP地址

InetAddress ip = InetAddress.getByName(txtAddr.getText().trim());

//设置对方的端口

int port = Integer.parseInt(txtPort2.getText().trim());

//创建发送包

byte b[] = str.getBytes();

DatagramPacket p = new DatagramPacket(b,b.length,ip,port);

//创建DatagramSocket发送

DatagramSocket socket = new DatagramSocket();

//发送

socket.send(p);

//清空发送框的内容

txtSend.setText("");

} catch (UnknownHostException e1) {

e1.printStackTrace();

} catch (SocketException e2) {

e2.printStackTrace();

} catch (IOException e3) {

e3.printStackTrace();

}

}else if(e.getSource()==btnClose){

System.exit(0);

}

}

}


该程序必须同启动2个实例才能实现在局域网聊天,互相设置对方的端口与IP地址即可。

本人从事软件项目开发20年,10年的Java工程师系列课程的教学工作,录制30多门精品视频课程,每门课程都包含有项目实战,上课PPT,及完整的源代码下载,有兴趣的朋友可以看看我的在线课堂,

关于网络即时通讯,多线程等技术的详细介绍内容很多,如果大家有兴趣可以看看我的 java从入门到精通+QQ即时通讯软件项目实训的教学视频,链接地址:http://edu.51cto.com/course/6946.html 

Java系列讲座二:Socket网络通信实现聊天软件项目讲解(UDP)

标签:tcp   网络通信   udp   socket   

原文地址:http://gkimlaps.blog.51cto.com/8307455/1947335

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!