java socket网络程序问题
初学java,遇到一个socket网络应用程序,请高手帮忙实现一下(源代码+注解)。题目:使用socket编写网络应用程序,要求实现:1)在客户与服务器同传输一个对象(是...
初学java,遇到一个socket网络应用程序,请高手帮忙实现一下(源代码+注解)。
题目:使用socket编写网络应用程序,要求实现:
1)在客户与服务器同传输一个对象(是对象,不是字符串什么的)
2)服务器采用多线程结构,至少支持2个客户。
会的帮忙写下哈,在线等啊 展开
题目:使用socket编写网络应用程序,要求实现:
1)在客户与服务器同传输一个对象(是对象,不是字符串什么的)
2)服务器采用多线程结构,至少支持2个客户。
会的帮忙写下哈,在线等啊 展开
4个回答
展开全部
我刚写的,包括三个类(SocketServer(服务器端),SocketClient(客户端),Student(学生对象)):
1.
package socket;
import java.io.IOException;
import java.io.InputStream;
import java.io.ObjectInputStream;
import java.net.ServerSocket;
import java.net.Socket;
import java.text.SimpleDateFormat;
public class SocketServer {
/**
* Socket服务器端
*/
private ServerSocket ss;
public SocketServer(int port)throws IOException{
ss=new ServerSocket(port);
}
public void startService(){
//启动服务器端的服务
Socket s=null;
while(true){
try {
s=ss.accept();//监听端口,得到服务器到客户端的连接
Thread service=new Service(s);//启动一个服务线称,将得到的socket传去
service.start();
} catch (IOException e) {
//
System.out.println("获得socket连接失败!");
}
}
}
private class Service extends Thread{
//一个服务端的socket 线称,用于和一个客户端的socket 进行通信
private Socket s;
public Service(Socket s){
this.s=s;
}
@Override
public void run() {
//
try {
InputStream is=s.getInputStream();
Thread getObject=new GetObject(is);//此线称用于重复读取客户端发来的object
getObject.start();
} catch (IOException e) {
//
e.printStackTrace();
}
}
private class GetObject extends Thread{
//用于读取客户端传来的对象
private ObjectInputStream ois;
public GetObject(InputStream is)throws IOException{
this.ois=new ObjectInputStream(is);
}
@Override
public void run() {
//
try {
Student s=(Student)ois.readObject();//读取对象
showObject(s);//输出对象内容
} catch (Exception e) {
//
e.printStackTrace();
}
}
public void showObject(Object obj){
//输出对象的内容
Student s=(Student)obj;
SimpleDateFormat format=new SimpleDateFormat("yy/MM/dd");
System.out.println(s.getName()+":"+format.format(s.getBirthday()));
}
}
}
public static void main(String[] args) {
//
try {
new SocketServer(8888).startService();
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}
2.
package socket;
import java.io.IOException;
import java.io.ObjectOutputStream;
import java.net.Socket;
public class SocketClient {
/**
* socket 编程客户端程序
*/
private Socket socket;
public SocketClient(String ip,int port)throws IOException{
this.socket=new Socket(ip,port);
}
public void sendObject(){
//向服务器端发送一个student 对象
Student s=new Student(1,"haha");
try {
ObjectOutputStream oos=new ObjectOutputStream(socket.getOutputStream());
oos.writeObject(s);
oos.flush();
} catch (IOException e) {
//
e.printStackTrace();
}
}
public static void main(String[] args) {
//
try {
new SocketClient("127.0.0.1",8888).sendObject();
} catch (IOException e) {
//
e.printStackTrace();
}
}
}
3.
package socket;
import java.io.Serializable;
import java.util.Date;
public class Student implements Serializable{
//一个学生类,对象要在网络传输必须实现 Serializable 接口
public static final long serialVersionUID = 42L;
private int id;
private String name;
private Date birthday;
public Student(int id,String name){
this.id=id;
this.name=name;
this.birthday=new Date();
}
public int getId() {
return id;
}
public void setId(int id) {
this.id = id;
}
public String getName() {
return name;
}
public void setName(String name) {
this.name = name;
}
public Date getBirthday() {
return birthday;
}
public void setBirthday(Date birthday) {
this.birthday = birthday;
}
}
在本人机器上测试通过,希望能满足你的要求!好久没进分了,如果基本满意就给个分吧!谢谢!
1.
package socket;
import java.io.IOException;
import java.io.InputStream;
import java.io.ObjectInputStream;
import java.net.ServerSocket;
import java.net.Socket;
import java.text.SimpleDateFormat;
public class SocketServer {
/**
* Socket服务器端
*/
private ServerSocket ss;
public SocketServer(int port)throws IOException{
ss=new ServerSocket(port);
}
public void startService(){
//启动服务器端的服务
Socket s=null;
while(true){
try {
s=ss.accept();//监听端口,得到服务器到客户端的连接
Thread service=new Service(s);//启动一个服务线称,将得到的socket传去
service.start();
} catch (IOException e) {
//
System.out.println("获得socket连接失败!");
}
}
}
private class Service extends Thread{
//一个服务端的socket 线称,用于和一个客户端的socket 进行通信
private Socket s;
public Service(Socket s){
this.s=s;
}
@Override
public void run() {
//
try {
InputStream is=s.getInputStream();
Thread getObject=new GetObject(is);//此线称用于重复读取客户端发来的object
getObject.start();
} catch (IOException e) {
//
e.printStackTrace();
}
}
private class GetObject extends Thread{
//用于读取客户端传来的对象
private ObjectInputStream ois;
public GetObject(InputStream is)throws IOException{
this.ois=new ObjectInputStream(is);
}
@Override
public void run() {
//
try {
Student s=(Student)ois.readObject();//读取对象
showObject(s);//输出对象内容
} catch (Exception e) {
//
e.printStackTrace();
}
}
public void showObject(Object obj){
//输出对象的内容
Student s=(Student)obj;
SimpleDateFormat format=new SimpleDateFormat("yy/MM/dd");
System.out.println(s.getName()+":"+format.format(s.getBirthday()));
}
}
}
public static void main(String[] args) {
//
try {
new SocketServer(8888).startService();
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}
2.
package socket;
import java.io.IOException;
import java.io.ObjectOutputStream;
import java.net.Socket;
public class SocketClient {
/**
* socket 编程客户端程序
*/
private Socket socket;
public SocketClient(String ip,int port)throws IOException{
this.socket=new Socket(ip,port);
}
public void sendObject(){
//向服务器端发送一个student 对象
Student s=new Student(1,"haha");
try {
ObjectOutputStream oos=new ObjectOutputStream(socket.getOutputStream());
oos.writeObject(s);
oos.flush();
} catch (IOException e) {
//
e.printStackTrace();
}
}
public static void main(String[] args) {
//
try {
new SocketClient("127.0.0.1",8888).sendObject();
} catch (IOException e) {
//
e.printStackTrace();
}
}
}
3.
package socket;
import java.io.Serializable;
import java.util.Date;
public class Student implements Serializable{
//一个学生类,对象要在网络传输必须实现 Serializable 接口
public static final long serialVersionUID = 42L;
private int id;
private String name;
private Date birthday;
public Student(int id,String name){
this.id=id;
this.name=name;
this.birthday=new Date();
}
public int getId() {
return id;
}
public void setId(int id) {
this.id = id;
}
public String getName() {
return name;
}
public void setName(String name) {
this.name = name;
}
public Date getBirthday() {
return birthday;
}
public void setBirthday(Date birthday) {
this.birthday = birthday;
}
}
在本人机器上测试通过,希望能满足你的要求!好久没进分了,如果基本满意就给个分吧!谢谢!
展开全部
take a look at java.io.ObjectInputStream/ObjectInputStream
it's your homework, isn't it?
it's your homework, isn't it?
已赞过
已踩过<
评论
收起
你对这个回答的评价是?
展开全部
如果晚上有时间的话,我写个!
已赞过
已踩过<
评论
收起
你对这个回答的评价是?
推荐律师服务:
若未解决您的问题,请您详细描述您的问题,通过百度律临进行免费专业咨询