Cách gửi và nhận đối tượng được tuần tự hóa trong kênh ổ cắm

Question

Tôi muốn truyền một đối tượng được tuần tự hóa qua một kênh ổ cắm. Tôi muốn tạo chuỗi "Hi friend" làm đối tượng được tuần tự hóa và sau đó viết đối tượng này vào kênh socket trong khi ở đầu kia tôi muốn đọc cùng một đối tượng và lấy dữ liệu.

Tất cả những điều này tôi muốn thực hiện bằng Java SocketChannel. làm như thế nào? Tôi đã thử như dưới đây, nhưng không nhận được bất kỳ dữ liệu nào ở phía người nhận.

private static void writeObject(Object obj, SelectionKey selectionKey) { 
    ObjectOutputStream oos; 
    try { 
     SocketChannel channel = (SocketChannel) selectionKey.channel(); 
     oos = new ObjectOutputStream(Channels.newOutputStream(channel)); 

     oos.writeObject(obj); 
    } catch (IOException ex) { 
     ex.printStackTrace(); 
    } 
} 

private static Object readObject(SelectionKey selectionKey) { 
    ObjectInputStream ois; 
    Object obj = new Object(); 
    SocketChannel channel = (SocketChannel) selectionKey.channel(); 
    try { 
     ois = new ObjectInputStream(Channels.newInputStream(channel)); 
     obj = ois.readObject(); 
    } catch (Exception ex) { 
     ex.printStackTrace(); 
    } 
    return obj; 
} 

Answer 1

xử lý SocketChannel của bạn có vẻ là không đầy đủ, xem hoàn ví dụ này cho SocketChannels chuyển một byte:

/* 
* Writer 
*/ 
import java.io.IOException; 
import java.io.ObjectOutputStream; 
import java.net.InetSocketAddress; 
import java.nio.channels.ServerSocketChannel; 
import java.nio.channels.SocketChannel; 

public class Sender { 
    public static void main(String[] args) throws IOException { 
     System.out.println("Sender Start"); 

     ServerSocketChannel ssChannel = ServerSocketChannel.open(); 
     ssChannel.configureBlocking(true); 
     int port = 12345; 
     ssChannel.socket().bind(new InetSocketAddress(port)); 

     String obj ="testtext"; 
     while (true) { 
      SocketChannel sChannel = ssChannel.accept(); 

      ObjectOutputStream oos = new 
         ObjectOutputStream(sChannel.socket().getOutputStream()); 
      oos.writeObject(obj); 
      oos.close(); 

      System.out.println("Connection ended"); 
     } 
    } 
} 

Và Reader

/* 
* Reader 
*/ 
import java.io.IOException; 
import java.io.ObjectInputStream; 
import java.net.InetSocketAddress; 
import java.nio.channels.SocketChannel; 

public class Receiver { 
    public static void main(String[] args) 
    throws IOException, ClassNotFoundException { 
     System.out.println("Receiver Start"); 

     SocketChannel sChannel = SocketChannel.open(); 
     sChannel.configureBlocking(true); 
     if (sChannel.connect(new InetSocketAddress("localhost", 12345))) { 

      ObjectInputStream ois = 
        new ObjectInputStream(sChannel.socket().getInputStream()); 

      String s = (String)ois.readObject(); 
      System.out.println("String is: '" + s + "'"); 
     } 

     System.out.println("End Receiver"); 
    } 
} 

Khi bạn lần đầu tiên bắt đầu Server , sau đó là Người nhận, bạn sẽ nhận được kết quả sau:

console Server

Sender Start 
Connection ended 

console người nhận

Receiver Start 
String is: 'testtext' 
End Receiver 

Đây không phải là giải pháp tốt nhất, nhưng sau việc bạn sử dụng câu hỏi ServerSocketChannel