网络编程(UDP聊天)
2014-01-06 14:52
260 查看
----------------------
ASP.Net+Android+IOS开发、.Net培训、期待与您交流! ----------------------
Datagram socket使用UDP来实现数据通讯,因此它不能保证数据能够到达目的地,但是由于它不需要专用的网络链接,所以它所需的资源相对少的多.
Java通过两个类DatagramSocket和DatagramPacket来支持Datagram
socket。DatagramSocket实现了Datagram socket的基本功能,而DatagramPacket则提供了对包的一些支持。
下面通过DatagramPacket和DatagramSocket实现一个简单额聊天程序
import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;
import java.net.SocketException;
public class ChatDemo {
public static void main(String[] args) {
try {
DatagramSocket sendsocket=new DatagramSocket();
DatagramSocket recesocket=new DatagramSocket(10050);
Send send=new Send(sendsocket);
Received received=new Received(recesocket);
//启动线程
new Thread(send).start();
new Thread(received).start();
} catch (SocketException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
//用于发送消息的一个类
static class Send implements Runnable{
//发送数据的对象
private DatagramSocket da=null;
public Send(DatagramSocket da)
{
this.da=da;
}
@Override
public void run() {
try {
//获取键盘录入
BufferedReader reader=new BufferedReader(new InputStreamReader(System.in));
String line=null;
while((line=reader.readLine())!=null)
{
//如果说了再见,就退出循环结束聊天
if(line.equals("886"))
{
break;
}
byte[] buffer=line.getBytes();
//用于存放从键盘录入的数据包
/*参数:
* 1.缓冲区中的数据
* 2.读取到的内容长度
* 3.用于发送到那个地方
* 4.表示的端口号
*/
DatagramPacket packet=new DatagramPacket(buffer, buffer.length,InetAddress.getByName("192.168.191.6"),10050);
//发送数据
da.send(packet);
}
} catch (Exception e) {
throw new RuntimeException("发送失败!");
}
}
}
//接受发送过来的数据
static class Received implements Runnable{
private DatagramSocket da=null;
public Received(DatagramSocket da)
{
this.da=da;
}
@Override
public void run() {
try {
while(true)
{
//顶一个缓冲区,用于存放读取的数据
byte[] buf=new byte[1024];
//传建一个 数据包对象
DatagramPacket packet=new DatagramPacket(buf, buf.length);
//把接受到的数据存放到缓冲区中
da.receive(packet);
//获取ip地址
String ip=packet.getAddress().getHostAddress();
//获取数据
String data=new String(packet.getData(),0,packet.getLength());
System.out.println(ip+":"+data);
}
} catch (Exception e) {
throw new RuntimeException("接受数据失败!");
}
}
}
}
----------------------
ASP.Net+Android+IOS开发、.Net培训、期待与您交流! ----------------------
ASP.Net+Android+IOS开发、.Net培训、期待与您交流! ----------------------
Datagram socket使用UDP来实现数据通讯,因此它不能保证数据能够到达目的地,但是由于它不需要专用的网络链接,所以它所需的资源相对少的多.
Java通过两个类DatagramSocket和DatagramPacket来支持Datagram
socket。DatagramSocket实现了Datagram socket的基本功能,而DatagramPacket则提供了对包的一些支持。
下面通过DatagramPacket和DatagramSocket实现一个简单额聊天程序
import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;
import java.net.SocketException;
public class ChatDemo {
public static void main(String[] args) {
try {
DatagramSocket sendsocket=new DatagramSocket();
DatagramSocket recesocket=new DatagramSocket(10050);
Send send=new Send(sendsocket);
Received received=new Received(recesocket);
//启动线程
new Thread(send).start();
new Thread(received).start();
} catch (SocketException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
//用于发送消息的一个类
static class Send implements Runnable{
//发送数据的对象
private DatagramSocket da=null;
public Send(DatagramSocket da)
{
this.da=da;
}
@Override
public void run() {
try {
//获取键盘录入
BufferedReader reader=new BufferedReader(new InputStreamReader(System.in));
String line=null;
while((line=reader.readLine())!=null)
{
//如果说了再见,就退出循环结束聊天
if(line.equals("886"))
{
break;
}
byte[] buffer=line.getBytes();
//用于存放从键盘录入的数据包
/*参数:
* 1.缓冲区中的数据
* 2.读取到的内容长度
* 3.用于发送到那个地方
* 4.表示的端口号
*/
DatagramPacket packet=new DatagramPacket(buffer, buffer.length,InetAddress.getByName("192.168.191.6"),10050);
//发送数据
da.send(packet);
}
} catch (Exception e) {
throw new RuntimeException("发送失败!");
}
}
}
//接受发送过来的数据
static class Received implements Runnable{
private DatagramSocket da=null;
public Received(DatagramSocket da)
{
this.da=da;
}
@Override
public void run() {
try {
while(true)
{
//顶一个缓冲区,用于存放读取的数据
byte[] buf=new byte[1024];
//传建一个 数据包对象
DatagramPacket packet=new DatagramPacket(buf, buf.length);
//把接受到的数据存放到缓冲区中
da.receive(packet);
//获取ip地址
String ip=packet.getAddress().getHostAddress();
//获取数据
String data=new String(packet.getData(),0,packet.getLength());
System.out.println(ip+":"+data);
}
} catch (Exception e) {
throw new RuntimeException("接受数据失败!");
}
}
}
}
----------------------
ASP.Net+Android+IOS开发、.Net培训、期待与您交流! ----------------------
相关文章推荐
- 网络编程UDP协议——聊天软件
- JAVA基础 day25 网络编程 IP类 UDP,TCP传输学习 简易聊天工具 TCP并发学习
- 黑马程序员_Java基础_网络编程_UDP传输协议编程,控制台聊天程序
- Java网络编程(UDP协议-聊天程序)
- 黑马程序员--10.网络编程--04.【UDP_键盘录入】【UDP_聊天】
- 网络编程学习笔记(二)UDP协议及聊天小程序的实现
- 网络编程与多线程的应用--基于socket udp编写一个简单聊天程序
- 【Java网络编程】基于 UDP 的聊天通信
- 网络编程(UDP-聊天)
- Delphi-网络编程-UDP聊天程序(转)
- Java基础---Java---网络编程---TCP、UDP、UDP-键盘录入方式数据、Socket、TCP复制文件、UDP-聊天
- Java基础---Java---网络编程---TCP、UDP、UDP-键盘录入方式数据、Socket、TCP复制文件、UDP-聊天
- java 网络编程二 UDP传输协议(例:2个进程进行聊天)
- 基于Udp的Socket网络编程聊天程序
- 网络编程 UDP 聊天功能
- 网络编程应用:基于UDP协议【实现聊天程序】--练习
- JAVA 网络编程(4) SOCKET UDP 单播聊天示例
- JAVA 网络编程 UDP(聊天程序)
- 网络编程UDP模仿QQ聊天功能
- Java_乔晓松_Java网络编程UDP实现黑窗口聊天