Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- private ServerSocket server;
- public void start1(){
- try {
- server = new ServerSocket(8000);
- while(true){
- Socket socket = server.accept();
- System.out.println("Ket noi thanh cong");
- read(socket);
- write(socket);
- }
- } catch (IOException e) {
- e.printStackTrace();
- }
- }
- public void read(Socket socket){
- Thread thread = new Thread(new Runnable() {
- @Override
- public void run() {
- try {
- DataInputStream dataInputStream = new DataInputStream(socket.getInputStream());
- while(true){
- String str = (String) dataInputStream.readUTF();
- System.out.println("Client send: "+str);
- }
- } catch (IOException e) {
- try {
- socket.close();
- } catch (IOException e1) {
- // TODO Auto-generated catch block
- e1.printStackTrace();
- }
- }
- }
- });
- thread.start();
- }
- public void write(Socket socket){
- try {
- DataOutputStream dataOutputStream = new DataOutputStream(socket.getOutputStream());
- dataOutputStream.writeUTF("Write thanh cong");
- dataOutputStream.flush();
- } catch (IOException e) {
- // TODO Auto-generated catch block
- }
- }
- public static void main(String[] args) {
- MyServer server = new MyServer();
- server.start1();
- }
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement