package com.ssl.sslsocket.testSocket;
import java.io.Serializable;
/**
* @author zjhe
* @date 2019/8/12 9:53
*/
public class Userimplements Serializable {
private Stringname;
private int age;
public StringgetName() {
return name;
}
public void setName(String name) {
this.name = name;
}
public int getAge() {
return age;
}
public void setAge(int age) {
this.age = age;
}
public User(String name, int age) {
super();
this.name = name;
this.age = age;
}
public User() {
}
@Override
public int hashCode() {
final int prime =31;
int result =1;
result = prime * result +age;
result = prime * result + ((name ==null) ?0 :name.hashCode());
return result;
}
@Override
public boolean equals(Object obj) {
if (this == obj)
return true;
if (obj ==null)
return false;
if (getClass() != obj.getClass())
return false;
User other = (User) obj;
if (age != other.age)
return false;
if (name ==null) {
if (other.name !=null)
return false;
}else if (!name.equals(other.name))
return false;
return true;
}
@Override
public StringtoString() {
return "User [name=" +name +", age=" +age +"]";
}
}
package com.ssl.sslsocket.testSocket;
import java.io.InputStream;
import java.io.ObjectOutputStream;
import java.net.Socket;
/**
* @author zjhe
* @date 2019/8/12 9:54
*/
public class Client {
public static void main(String[] args)throws Exception {
Socket socket=new Socket("localhost", 9999);//监听端口
ObjectOutputStream out=new ObjectOutputStream(socket.getOutputStream());//包装对象流
out.writeObject(new User("小明", 21));//写入对象
socket.shutdownOutput();//关闭流的占用
//获取服务器发过来的消息
InputStream in = socket.getInputStream();
byte[] b=new byte[1024];
in.read(b);
System.out.println(new String(b,0,b.length));
//关闭流
in.close();
out.close();
socket.close();
}
}
package com.ssl.sslsocket.testSocket;
import java.net.ServerSocket;
import java.net.Socket;
/**
* @author zjhe
* @date 2019/8/12 9:55
*/
public class Server {
public static void main(String[] args)throws Exception {
ServerSocket socket=new ServerSocket(9999);//监听端口
//循环监听接收各个客户端连接
while (true) {
Socket client = socket.accept();
//开启多线程接受客户端信息
ThreadServer ts=new ThreadServer(client);
new Thread(ts).start();
}
}
}
package com.ssl.sslsocket.testSocket;
import java.io.IOException;
import java.io.ObjectInputStream;
import java.io.OutputStream;
import java.net.Socket;
/**
* @author zjhe
* @date 2019/8/12 9:55
*/
public class ThreadServerimplements Runnable {
private Socketclient;
public ThreadServer(Socket client) {
this.client=client;
}
@Override
public void run() {
try {
//包装对象接收流
ObjectInputStream in=new ObjectInputStream(client.getInputStream());
User user = (User) in.readObject();//读取对象
//比较是否符合标准.符合回答成功,否则失败
OutputStream out =client.getOutputStream();
if((new User("小明",21)).equals(user)){
out.write("登陆成功".getBytes());
System.out.println(user);
}else{
out.write("登陆失败".getBytes());
}
client.shutdownOutput();
out.close();
in.close();
client.close();
}catch (IOException | ClassNotFoundException e) {
e.printStackTrace();
}
}
}
