您的位置:

java程序发送接收对象,java 对象间消息传递

本文目录一览:

Java udp如何通过一个对象完成接收和发送数据

//注意,本地ip以及端口,广播Ip以及端口,可根据自己的电脑实际情况定.我的三段是2

//思路:我用的udp启动服务端,进行侦听,如果有消息,就该频段广播一次..

//客户端使用多线程,一个发送服务端,一个接受广播..就当我复习了一次...!

import java.io.IOException;

import java.net.DatagramPacket;

import java.net.DatagramSocket;

import java.net.InetAddress;

import java.net.InetSocketAddress;

import java.net.SocketAddress;

import java.util.Scanner;

public class UdpTest {

class SendTest{

private int count=1;

private Scanner sc;

private byte[] by,by2; 

private InetAddress ip;

private SocketAddress sd1,sd2;

private DatagramSocket ds,ds2;

private DatagramPacket dp,dp2;

SendTest(String ipName,int port) throws Exception{

sc=new Scanner(System.in);

ip=InetAddress.getByName(ipName);

sd1=new InetSocketAddress(ip,port);//发送的目标:ip+端口

sd2=new InetSocketAddress(19823);//己方,省略ip,默认自己本地地址

ds=new DatagramSocket();//参数为自己的标识

//接受

by2=new byte[1024];

ds2=new DatagramSocket(sd2);

send();

}

private void send() throws IOException {

new Thread() {

public void run() {

while(true) {

by=sc.nextLine().getBytes();

dp=new DatagramPacket(by,by.length,sd1);//数组,数组长度,目标ip+端口

try {

ds.send(dp);

} catch (IOException e) {

e.printStackTrace();

}//推送服务;

System.out.println("老马第:"+count+++"条信息发送完成!");

}

}

}.start();

new Thread() {

public void run() {

while(true) {

dp2=new DatagramPacket(by2,by2.length);

try {

ds2.receive(dp2);

System.out.println("老马接受到一条广播可能来自老宋:"+new String(by2,0,dp2.getLength()));

} catch (IOException e) {

e.printStackTrace();

}

}

}

}.start();

}

}

class AccepTest{

private byte[] by; 

private SocketAddress sd1,sd2;

private DatagramSocket ds;

private DatagramPacket dp;

private int count=0;

AccepTest() throws Exception{

by=new byte[1024];

sd1=new InetSocketAddress("192.168.2.255",19823);//广播

sd2=new InetSocketAddress(19822);//己方,省略ip,默认自己本地地址

ds=new DatagramSocket(sd2);//参数为自己的标识,这是用来接受的.....

accepts();

}

private void accepts() throws IOException {

while(true) {

count++;

System.out.println("老宋的服务器接受第:"+count+"次数据:...");

dp=new DatagramPacket(by,by.length);//数组,数组长度,仅仅用来接收;

ds.receive(dp); //接受服务;

String str=new String(by,0,dp.getLength());

System.out.println("老宋接受到数据---------"+str);

System.out.println();

//广播..

by=("插个广播:"+str+"....谁发的??").getBytes();

dp=new DatagramPacket(by,by.length,sd1);

ds.send(dp);

}

}

}

public static void main(String[] args) throws Exception {

new Thread() {

public void run() {

try {

new UdpTest().new AccepTest();

} catch (Exception e) {

e.printStackTrace();

}

}

}.start();

new Thread() {

public void run() {

try {

new UdpTest().new SendTest("127.0.0.1",19822);

} catch (Exception e) {

e.printStackTrace();

}

}

}.start();

}

}

能够使用java的UDP接口传递和接收对象吗

可以做到

//对像变成节数组

ByteArrayOutputStream buffers = new ByteArrayOutputStream();

try{

ObjectOutputStream out = new ObjectOutputStream(buffers);

out.writeObject(你的对像变量);

out.close();

}catch(Exception e){

System.err.print(e.getMessage());

return null;

}

return buffers.toByteArray();//这里返回的就是你对像的字节数组了

//字节数组还原为对像

data[]=.....

你对像的类型 obj;

try{

ByteArrayInputStream buffers = new ByteArrayInputStream(data);

ObjectInputStream in = new ObjectInputStream(buffers);

obj=(你对像的类型) in.readObject(); //obj就是你还原回来的对像了

in.close();

}catch(Exception e){

System.err.print(e.getMessage());

}

用JAVA写一个SOCKET 接收TCP发来的消息

public class TalkServer{

public static void main(String args[]) {

try{

ServerSocket server=null;

try{

server=new ServerSocket(4700);

//创建一个ServerSocket在端口4700监听客户请求

}catch(Exception e) {

System.out.println("can not listen to:"+e);

//出错,打印出错信息

}

Socket socket=null;

try{

socket=server.accept();

//使用accept()阻塞等待客户请求,有客户

//请求到来则产生一个Socket对象,并继续执行

}catch(Exception e) {

System.out.println("Error."+e);

//出错,打印出错信息

}

String line;

BufferedReader is=new BufferedReader(new InputStreamReader(socket.getInputStream()));

 //由Socket对象得到输入流,并构造相应的BufferedReader对象

PrintWriter os=newPrintWriter(socket.getOutputStream());

 //由Socket对象得到输出流,并构造PrintWriter对象

BufferedReader sin=new BufferedReader(new InputStreamReader(System.in));

 //由系统标准输入设备构造BufferedReader对象

System.out.println("Client:"+is.readLine());

//在标准输出上打印从客户端读入的字符串

line=sin.readLine();

//从标准输入读入一字符串

while(!line.equals("bye")){

//如果该字符串为 "bye",则停止循环

os.println(line);

//向客户端输出该字符串

os.flush();

//刷新输出流,使Client马上收到该字符串

System.out.println("Server:"+line);

//在系统标准输出上打印读入的字符串

System.out.println("Client:"+is.readLine());

//从Client读入一字符串,并打印到标准输出上

line=sin.readLine();

//从系统标准输入读入一字符串

}  //继续循环

os.close(); //关闭Socket输出流

is.close(); //关闭Socket输入流

socket.close(); //关闭Socket

server.close(); //关闭ServerSocket

}catch(Exception e){

System.out.println("Error:"+e);

//出错,打印出错信息

}

}

}

java怎么接受对象作为参数的方法?

对象做参数,传过去的是地址。 所以你在你调用的方法里面可以修改对象的某些属性(值),基本数据类型就不可以。Java中数组也是传递地址的。