用udp方式进行聊天的java实现
2008-03-25 10:30
288 查看
导读:
bootcool 原作
我最近也在研究用java实现oicq。
这是我的客户端的简单编程实现。
主要是通过udp方式,实现用户间的对话。
其中运用了序列化类的方法。
以下是源代码,请多提意见。
//发送消息类
Message.java
import java.io.Serializable;
public class Message implements Serializable{
private String msg;
private String id;
private String destid;
public Message(String msg, String id, String destid) {
this.msg = msg;
this.id = id;
this.destid = destid;
}
//获得消息内容
public String getMessage() {
return msg;
}
//获得发送方的ip
public String getID() {
return id;
}
//获得接受方的ip
public String getDestID() {
return destid;
}
}
//接受方
Receiver.java
import java.net.*;
import java.io.*;
public class Receiver extends Thread {
private Message msg;
private DatagramPacket packet;
private DatagramSocket socket;
private byte[] recvBuf = new byte[500];
public Receiver() {
try{
//创建udp包以接受数据。
packet = new DatagramPacke(recvBuf,recvBuf.length);
//创建接受方的udp端口以接收数据
socket = new DatagramSocket(7002);
}
catch(Exception e){}
}
public void run() {
try {
while(true){
//接受数据
socket.receive(packet);
ByteArrayInputStream byteStream = new
ByteArrayInputStream(recvBuf);
ObjectInputStream is = new ObjectInputStream(new
BufferedInputStream(byteStram));
Object o = is.readObject();
msg = (Message)o;
is.close();
System.out.println(msg.getMessage());
}
}
catch(Throwable t) {
t.printStackTrace();
}
}
}
//发送方
Sender.java
import java.net.*;
import java.io.*;
public class Sender extends Thread {
private Message msg;
private DatagramSocket socket;
private DatagramPacket packet;
public Sender(Message msg) {
try {
this.msg = msg;
//获得目的方的ip地址
String destID = msg.getDestID();
//获得将要发送的消息内容
String destID = msg.getDestIDString message = msg.getMessage();
ByteArrayOutputStream byteStream = new ByteArrayOutputStream(500);
ObjectOutputStream os = new ObjectOutputStream(new
BufferedOutputStream(byteStream));
os.writeObject(msg);
os.flush();
byte[] sendBuf = byteStream.toByteArray();
//创建udp数据包以发送数据
packet = new DatagramPacket(sendBuf,sendBuf.length,
InetAddress.getByName(destID),7002);
//创建发送udp套接字,指定套接字口。
socket = new DatagramSocket(7000);
os.close();
}
catch(Throwable t) {
t.printStackTrace();
}
}
public void run() {
try {
//发送消息
socket.send(packet);
//发送完毕关闭套接字。
socket.close();
}
catch(Throwable t) {
t.printStackTrace();
}
}
}
//测试程序
Udp_Chat.java
import java.io.*;
import java.net.*;
public class UDP_Chat {
public UDP_Chat(String s){
}
public static void main(String args[])throws Exception{
Message a = new Message("阿飞的卡","211.92.155.200" ,"211.92.155.200");
new Sender(a).start();
new Receiver().start();
}
}
参考文章:Java 技巧 40:通过数据报包输送对象 利用数据报包在网上输送 Java 对象
bootcool@263.net
bootcool 原作 我最近也在研究用java实现oicq。 这是我的客户端的简单编程实现。 主要是通过udp方式,实现用户间的对话。 其中运用了序列化类的方法。 以下是源代码,请多提意见。 //发送消息类 Message.java import java.io.Serializable; public class Message implements Serializable{ private String msg; private String id; private String destid; public Message(String msg, String id, String destid) { this.msg = msg; this.id = id; this.destid = destid; } //获得消息内容 public String getMessage() { return msg; } //获得发送方的ip public String getID() { return id; } //获得接受方的ip public String getDestID() { return destid; } } //接受方 Receiver.java import java.net.*; import java.io.*; public class Receiver extends Thread { private Message msg; private DatagramPacket packet; private DatagramSocket socket; private byte[] recvBuf = new byte[500]; public Receiver() { try{ //创建udp包以接受数据。 packet = new DatagramPacke(recvBuf,recvBuf.length); //创建接受方的udp端口以接收数据 socket = new DatagramSocket(7002); } catch(Exception e){} } public void run() { try { while(true){ //接受数据 socket.receive(packet); ByteArrayInputStream byteStream = new ByteArrayInputStream(recvBuf); ObjectInputStream is = new ObjectInputStream(new BufferedInputStream(byteStram)); Object o = is.readObject(); msg = (Message)o; is.close(); System.out.println(msg.getMessage()); } } catch(Throwable t) { t.printStackTrace(); } } } //发送方 Sender.java import java.net.*; import java.io.*; public class Sender extends Thread { private Message msg; private DatagramSocket socket; private DatagramPacket packet; public Sender(Message msg) { try { this.msg = msg; //获得目的方的ip地址 String destID = msg.getDestID(); //获得将要发送的消息内容 String destID = msg.getDestIDString message = msg.getMessage(); ByteArrayOutputStream byteStream = new ByteArrayOutputStream(500); ObjectOutputStream os = new ObjectOutputStream(new BufferedOutputStream(byteStream)); os.writeObject(msg); os.flush(); byte[] sendBuf = byteStream.toByteArray(); //创建udp数据包以发送数据 packet = new DatagramPacket(sendBuf,sendBuf.length, InetAddress.getByName(destID),7002); //创建发送udp套接字,指定套接字口。 socket = new DatagramSocket(7000); os.close(); } catch(Throwable t) { t.printStackTrace(); } } public void run() { try { //发送消息 socket.send(packet); //发送完毕关闭套接字。 socket.close(); } catch(Throwable t) { t.printStackTrace(); } } } //测试程序 Udp_Chat.java import java.io.*; import java.net.*; public class UDP_Chat { public UDP_Chat(String s){ } public static void main(String args[])throws Exception{ Message a = new Message("阿飞的卡","211.92.155.200" ,"211.92.155.200"); new Sender(a).start(); new Receiver().start(); } } 参考文章:Java 技巧 40:通过数据报包输送对象 利用数据报包在网上输送 Java 对象 bootcool@263.net
本文转自
http://www.cn-java.com/www1/?action-viewnews-itemid-882
bootcool 原作
我最近也在研究用java实现oicq。
这是我的客户端的简单编程实现。
主要是通过udp方式,实现用户间的对话。
其中运用了序列化类的方法。
以下是源代码,请多提意见。
//发送消息类
Message.java
import java.io.Serializable;
public class Message implements Serializable{
private String msg;
private String id;
private String destid;
public Message(String msg, String id, String destid) {
this.msg = msg;
this.id = id;
this.destid = destid;
}
//获得消息内容
public String getMessage() {
return msg;
}
//获得发送方的ip
public String getID() {
return id;
}
//获得接受方的ip
public String getDestID() {
return destid;
}
}
//接受方
Receiver.java
import java.net.*;
import java.io.*;
public class Receiver extends Thread {
private Message msg;
private DatagramPacket packet;
private DatagramSocket socket;
private byte[] recvBuf = new byte[500];
public Receiver() {
try{
//创建udp包以接受数据。
packet = new DatagramPacke(recvBuf,recvBuf.length);
//创建接受方的udp端口以接收数据
socket = new DatagramSocket(7002);
}
catch(Exception e){}
}
public void run() {
try {
while(true){
//接受数据
socket.receive(packet);
ByteArrayInputStream byteStream = new
ByteArrayInputStream(recvBuf);
ObjectInputStream is = new ObjectInputStream(new
BufferedInputStream(byteStram));
Object o = is.readObject();
msg = (Message)o;
is.close();
System.out.println(msg.getMessage());
}
}
catch(Throwable t) {
t.printStackTrace();
}
}
}
//发送方
Sender.java
import java.net.*;
import java.io.*;
public class Sender extends Thread {
private Message msg;
private DatagramSocket socket;
private DatagramPacket packet;
public Sender(Message msg) {
try {
this.msg = msg;
//获得目的方的ip地址
String destID = msg.getDestID();
//获得将要发送的消息内容
String destID = msg.getDestIDString message = msg.getMessage();
ByteArrayOutputStream byteStream = new ByteArrayOutputStream(500);
ObjectOutputStream os = new ObjectOutputStream(new
BufferedOutputStream(byteStream));
os.writeObject(msg);
os.flush();
byte[] sendBuf = byteStream.toByteArray();
//创建udp数据包以发送数据
packet = new DatagramPacket(sendBuf,sendBuf.length,
InetAddress.getByName(destID),7002);
//创建发送udp套接字,指定套接字口。
socket = new DatagramSocket(7000);
os.close();
}
catch(Throwable t) {
t.printStackTrace();
}
}
public void run() {
try {
//发送消息
socket.send(packet);
//发送完毕关闭套接字。
socket.close();
}
catch(Throwable t) {
t.printStackTrace();
}
}
}
//测试程序
Udp_Chat.java
import java.io.*;
import java.net.*;
public class UDP_Chat {
public UDP_Chat(String s){
}
public static void main(String args[])throws Exception{
Message a = new Message("阿飞的卡","211.92.155.200" ,"211.92.155.200");
new Sender(a).start();
new Receiver().start();
}
}
参考文章:Java 技巧 40:通过数据报包输送对象 利用数据报包在网上输送 Java 对象
bootcool@263.net
bootcool 原作 我最近也在研究用java实现oicq。 这是我的客户端的简单编程实现。 主要是通过udp方式,实现用户间的对话。 其中运用了序列化类的方法。 以下是源代码,请多提意见。 //发送消息类 Message.java import java.io.Serializable; public class Message implements Serializable{ private String msg; private String id; private String destid; public Message(String msg, String id, String destid) { this.msg = msg; this.id = id; this.destid = destid; } //获得消息内容 public String getMessage() { return msg; } //获得发送方的ip public String getID() { return id; } //获得接受方的ip public String getDestID() { return destid; } } //接受方 Receiver.java import java.net.*; import java.io.*; public class Receiver extends Thread { private Message msg; private DatagramPacket packet; private DatagramSocket socket; private byte[] recvBuf = new byte[500]; public Receiver() { try{ //创建udp包以接受数据。 packet = new DatagramPacke(recvBuf,recvBuf.length); //创建接受方的udp端口以接收数据 socket = new DatagramSocket(7002); } catch(Exception e){} } public void run() { try { while(true){ //接受数据 socket.receive(packet); ByteArrayInputStream byteStream = new ByteArrayInputStream(recvBuf); ObjectInputStream is = new ObjectInputStream(new BufferedInputStream(byteStram)); Object o = is.readObject(); msg = (Message)o; is.close(); System.out.println(msg.getMessage()); } } catch(Throwable t) { t.printStackTrace(); } } } //发送方 Sender.java import java.net.*; import java.io.*; public class Sender extends Thread { private Message msg; private DatagramSocket socket; private DatagramPacket packet; public Sender(Message msg) { try { this.msg = msg; //获得目的方的ip地址 String destID = msg.getDestID(); //获得将要发送的消息内容 String destID = msg.getDestIDString message = msg.getMessage(); ByteArrayOutputStream byteStream = new ByteArrayOutputStream(500); ObjectOutputStream os = new ObjectOutputStream(new BufferedOutputStream(byteStream)); os.writeObject(msg); os.flush(); byte[] sendBuf = byteStream.toByteArray(); //创建udp数据包以发送数据 packet = new DatagramPacket(sendBuf,sendBuf.length, InetAddress.getByName(destID),7002); //创建发送udp套接字,指定套接字口。 socket = new DatagramSocket(7000); os.close(); } catch(Throwable t) { t.printStackTrace(); } } public void run() { try { //发送消息 socket.send(packet); //发送完毕关闭套接字。 socket.close(); } catch(Throwable t) { t.printStackTrace(); } } } //测试程序 Udp_Chat.java import java.io.*; import java.net.*; public class UDP_Chat { public UDP_Chat(String s){ } public static void main(String args[])throws Exception{ Message a = new Message("阿飞的卡","211.92.155.200" ,"211.92.155.200"); new Sender(a).start(); new Receiver().start(); } } 参考文章:Java 技巧 40:通过数据报包输送对象 利用数据报包在网上输送 Java 对象 bootcool@263.net
本文转自
http://www.cn-java.com/www1/?action-viewnews-itemid-882
相关文章推荐
- 用udp方式进行聊天的java实现
- JAVA系列课程讲座二:使用Socket通信实现简单聊天通信程序(UDP方式)
- 基于java实现的UDP多用户聊天应用
- 在DOS下的java聊天小程序--基于UDP传输方式
- java使用UDP数据报通讯方式QQ聊天系统:服务器、客户端
- JAVA实现UDP组播聊天程序
- JAVA 多线程实现简单UDP一对一聊天
- Java UDP使用Socket进行网络聊天(1)
- 黑马程序员-JAVA学习之用多线程实现简单UDP聊天程序
- 今天无意中发现JavaBean类基本都要求实现了Serializable接口,以前只是知道序列化以后,可以通过io流的方式将对象序列化和反序列化,进行存取,但不知道为什么需要序列化,今天总结一下
- Java基础---Java---网络编程---TCP、UDP、UDP-键盘录入方式数据、Socket、TCP复制文件、UDP-聊天
- JAVA 多线程实现聊天(UDP通信 )
- Java系列讲座二:Socket网络通信实现聊天软件项目讲解(UDP)
- Java 中UDP原理机制及实现方式介绍(建议阅读者阅读前了解下Java的基础知识,一方便理解)
- java基于udp实现键盘录入聊天
- Java系列讲座二:Socket网络通信实现聊天软件项目讲解(UDP)
- java 使用面向对象方式实现录入学生信息,取出成绩最大值、最小值、平均值、对其进行排序
- java中进行socket编程实现tcp、udp协议总结
- java中进行socket编程实现tcp、udp协议总结
- Java用Smack实现简单地通过OpenFire与其他人进行聊天