40 lines
948 B
Java
40 lines
948 B
Java
package part1.Server.server.impl;
|
|
|
|
|
|
import lombok.AllArgsConstructor;
|
|
import part1.Server.provider.ServiceProvider;
|
|
import part1.Server.server.RpcServer;
|
|
import part1.Server.server.work.WorkThread;
|
|
|
|
import java.io.IOException;
|
|
import java.net.ServerSocket;
|
|
import java.net.Socket;
|
|
|
|
/**
|
|
* @author wxx
|
|
* @version 1.0
|
|
* @create 2024/2/12 11:37
|
|
*/
|
|
@AllArgsConstructor
|
|
public class SimpleRPCRPCServer implements RpcServer {
|
|
private ServiceProvider serviceProvide;
|
|
@Override
|
|
public void start(int port) {
|
|
try {
|
|
ServerSocket serverSocket=new ServerSocket(port);
|
|
System.out.println("服务器启动了");
|
|
while (true) {
|
|
Socket socket = serverSocket.accept();
|
|
new Thread(new WorkThread(socket,serviceProvide)).start();
|
|
}
|
|
} catch (IOException e) {
|
|
e.printStackTrace();
|
|
}
|
|
}
|
|
|
|
@Override
|
|
public void stop() {
|
|
|
|
}
|
|
}
|