* 基于UDP协议的聊天程序
*
*2007.9.18
* */
//导入包
import java.awt.*
import java.awt.event.*
import java.awt.event.ActionEvent
import java.awt.event.ActionListener
import javax.swing.*
import java.net.*
public class Chat extends JFrame implements ActionListener
{
//广播地址或者对方的地址
public static final String sendIP = "172.18.8.255"
//发送端口9527
public static final int sendPort = 9527
JPanel p = new JPanel()
List lst = new List() //消桐信息显示
JTextField txtIP = new JTextField(18)//填写IP地址
JTextField txtMSG = new JTextField(20)//填写发送消息
JLabel lblIP = new JLabel("IP地址:")
JLabel lblMSG = new JLabel("消息:")
JButton btnSend = new JButton("发送")
byte [] buf
//局旁轮定义DatagramSocket的对象必须进行异常处理
//发送和接收数据报包的套接字
DatagramSocket ds = null
//=============构造函数=====================
public Chat()
{
CreateInterFace()
//注册消息框监听器
txtMSG.addActionListener(this)
btnSend.addActionListener(this)
try
{
//端口:9527
ds =new DatagramSocket(sendPort)
}
catch(Exception ex)
{
ex.printStackTrace()
}
//============接受消息============
//匿名类
new Thread(new Runnable()
{
public void run()
{
byte buf[] = new byte[1024]
//表示接启旦受数据报包
while(true)
{
try
{
DatagramPacket dp = new DatagramPacket(buf,1024,InetAddress.getByName(txtIP.getText()),sendPort)
ds.receive(dp)
lst.add("【消息来自】◆" + dp.getAddress().getHostAddress() + "◆"+"【说】:" + new String (buf,0,dp.getLength()) /*+ dp.getPort()*/,0)
}
catch(Exception e)
{
if(ds.isClosed())
{
e.printStackTrace()
}
}
}
}
}).start()
//关闭窗体事件
this.addWindowListener(new WindowAdapter()
{
public void windowClosing(WindowEvent w)
{
System.out.println("test")
int n=JOptionPane.showConfirmDialog(null,"是否要退出?","退出",JOptionPane.YES_NO_OPTION)
if(n==JOptionPane.YES_OPTION)
{
dispose()
System.exit(0)
ds.close()//关闭ds对象//关闭数据报套接字
}
}
})
}
//界面设计布局
public void CreateInterFace()
{
this.add(lst,BorderLayout.CENTER)
this.add(p,BorderLayout.SOUTH)
p.add(lblIP)
p.add(txtIP)
p.add(lblMSG)
p.add(txtMSG)
p.add(btnSend)
txtIP.setText(sendIP)
//背景颜色
lst.setBackground(Color.yellow)
//JAVA默认风格
this.setUndecorated(true)
this.getRootPane().setWindowDecorationStyle(JRootPane.FRAME)
this.setSize(600,500)
this.setTitle("〓聊天室〓")
this.setResizable(false)//不能改变窗体大小
this.setLocationRelativeTo(null)//窗体居中
this.setDefaultCloseOperation(JFrame.DO_NOTHING_ON_CLOSE)
this.setVisible(true)
txtMSG.requestFocus()//消息框得到焦点
}
//===============================Main函数===============================
public static void main(String[]args)
{
new Chat()
}
//================================发送消息===============================
//消息框回车发送消息事件
public void actionPerformed(ActionEvent e)
{
//得到文本内容
buf = txtMSG.getText().getBytes()
//判断消息框是否为空
if (txtMSG.getText().length()==0)
{
JOptionPane.showMessageDialog(null,"发送消息不能为空","提示",JOptionPane.WARNING_MESSAGE)
}
else{
try
{
InetAddress address = InetAddress.getByName(sendIP)
DatagramPacket dp = new DatagramPacket(buf,buf.length,InetAddress.getByName(txtIP.getText()),sendPort)
ds.send(dp)
}
catch(Exception ex)
{
ex.printStackTrace()
}
}
txtMSG.setText("")//清空消息框
//点发送按钮发送消息事件
if(e.getSource()==btnSend)
{
buf = txtMSG.getText().getBytes()
try
{
DatagramPacket dp = new DatagramPacket(buf,buf.length,InetAddress.getByName(txtIP.getText()),sendPort)
}
catch(Exception ex)
{
ex.printStackTrace()
}
txtMSG.setText("")//清空消息框
txtMSG.requestFocus()
}
}
}
Java可以使用Socket编程实现聊天功能。Socket是一种网络通信协议,它可以在不同的主机之间传输数据。在聊天功能中,一般有客户端和服务器两个角色。客户端是发送消息的一方,它需要创建一个Socket对象,指定要连接的服务器的IP地址和端口号。然后,客户端通过Socket对象的输入输出流向服务器发送和接收消茄扒息。在接收消息时,客户端需要启动一个线程不断监听服务器的消息,并将接收到的消息展示给用户。
服务器端则是接竖纳租收和转发消息的一方。服务器需要创建一个ServerSocket对象,指定监听的端口号。当有客户端连接到服务器时,服务器通过Socket对象的输入输出流向客户端发送和接收消息。在接收到客户端的消息后,服务器需要将消息转发给其他客户端,以实现聊天室的功能。
需要注意的是,在聊天功能中,数据的传输是通过网络进行的,因此需要考虑数据传输的余兆稳定性和安全性。例如,可以使用加密算法对聊天数据进行加密,确保聊天数据的安全性。此外,在多用户同时连接的情况下,还需要考虑服务器的并发处理能力。
要实现 Java 的一对一聊天室,可以使用 Socket 编程实现基于 TCP 协议的通信。
以下是一些大致的步骤:
创建服务器端程序:创建一个服务器端程序,等待客户端的连接请求。在连接请求到来时,服务器会创建一个新的线程来处理这个连接请求。
创建客户端程序:创建一个客户端程序,连接服务器端程序。在连接成功后,客户端可以发送消息给服务器,服务器会将这些消息转发给接收方。
实现消息传输:在客户端和服务器之间,通过输入流和输出流传输数据。客户端向服务器发送消息时,使用输出流将消息发送给服务器;服务器收到消息后,使用输入流读取消息内容。
实现一对一通信:当客户端和服务器建立连接后,可以通过指定接收方的用户名来实现一对一通信。客户端向服务器发送消息时,需要指定接收方的用户名,卜毁悉服务器将根据用户名查找对应的客户端,并将消息发送给指定的客户端。
实现界面交互:可以使用 JavaFX、Swing 等图形界面库,实现聊天窗口的显示和用户的输入。用户在聊天窗口中输入消息后,客户端将消息发送给服务器,服务器将消息转发给接收方。
需要注意的是,为了保证通信的可靠性和安全性,需要对数据进行加密和校余者验,同时也需要考虑并发访问的问题,防止多个线程同时访型乎问导致数据错乱的情况发生。
欢迎分享,转载请注明来源:内存溢出
评论列表(0条)