java雙向通信

『壹』 java編程中，Socket通信是怎麼實現的

java編程對於Socket之間的通信過程如下：

服務端往Socket的輸出流裡面寫東西，客戶端就可以通過Socket的輸入流讀取對應的內容。Socket與Socket之間是雙向連通的，所以客戶端也可以往對應的Socket輸出流裡面寫東西，然後服務端對應的Socket的輸入流就可以讀出對應的內容。下面來看一些服務端與客戶端通信的例子：

publicclassServer{

publicstaticvoidmain(Stringargs[])throwsIOException{
//為了簡單起見，所有的異常信息都往外拋
intport=8899;
//定義一個ServerSocket監聽在埠8899上
ServerSocketserver=newServerSocket(port);
//server嘗試接收其他Socket的連接請求，server的accept方法是阻塞式的
Socketsocket=server.accept();
//跟客戶端建立好連接之後，我們就可以獲取socket的InputStream，並從中讀取客戶端發過來的信息了。
Readerreader=newInputStreamReader(socket.getInputStream());
charchars[]=newchar[64];
intlen;
StringBuildersb=newStringBuilder();
while((len=reader.read(chars))!=-1){
sb.append(newString(chars,0,len));
}
System.out.println("fromclient:"+sb);
reader.close();
socket.close();
server.close();
}

}

客戶端代碼
Java代碼publicclassClient{

publicstaticvoidmain(Stringargs[])throwsException{
//為了簡單起見，所有的異常都直接往外拋
Stringhost="127.0.0.1";//要連接的服務端IP地址
intport=8899;//要連接的服務端對應的監聽埠
//與服務端建立連接
Socketclient=newSocket(host,port);
//建立連接後就可以往服務端寫數據了
Writerwriter=newOutputStreamWriter(client.getOutputStream());
writer.write("HelloServer.");
writer.flush();//寫完後要記得flush
writer.close();
client.close();
}

}

『貳』 怎麼為JAVA NIO或Netty程序設置網路通信代理

服務端

// 設置一個處理客戶端消息和各種消息事件的類(Handler)bootstrap.setPipelineFactory(newChannelPipelineFactory() { @Override publicChannelPipeline getPipeline()throwsException { returnChannels.pipeline( newObjectDecoder(ClassResolvers.cacheDisabled(this .getClass().getClassLoader())), newObjectServerHandler()); }});

客戶端

// 設置一個處理服務端消息和各種消息事件的類(Handler)
bootstrap.setPipelineFactory(newChannelPipelineFactory() { @Override publicChannelPipeline getPipeline()throwsException { returnChannels.pipeline(newObjectEncoder(), newObjectClientHandler()); }});

要傳遞對象，自然要有一個被傳遞模型，一個簡單的Pojo，當然，實現序列化介面是必須的。

/** * @author lihzh * @alia OneCoder * @bloghttp://www.coderli.com */public class Command implementsSerializable { = 7590999461767050471L; privateString actionName; publicString getActionName() { returnactionName; } publicvoidsetActionName(String actionName) { this.actionName = actionName; }}

服務端和客戶端里，我們自定義的Handler實現如下：

ObjectServerHandler .java

/** * 對象傳遞服務端代碼 * * @author lihzh * @alia OneCoder * @bloghttp://www.coderli.com */public class ObjectServerHandler extendsSimpleChannelHandler { /** * 當接受到消息的時候觸發 */ @Override publicvoidmessageReceived(ChannelHandlerContext ctx, MessageEvent e) throwsException { Command command = (Command) e.getMessage(); // 列印看看是不是我們剛才傳過來的那個 System.out.println(command.getActionName()); }}

ObjectClientHandler .java

/** * 對象傳遞，客戶端代碼 * * @author lihzh * @alia OneCoder * @bloghttp://www.coderli.com */public class ObjectClientHandler extendsSimpleChannelHandler { /** * 當綁定到服務端的時候觸發，給服務端發消息。 * * @author lihzh * @alia OneCoder */ @Override publicvoidchannelConnected(ChannelHandlerContext ctx, ChannelStateEvent e) { // 向服務端發送Object信息 sendObject(e.getChannel()); } /** * 發送Object * * @param channel * @author lihzh * @alia OneCoder */ privatevoidsendObject(Channel channel) { Command command =newCommand(); command.setActionName("Hello action."); channel.write(command); } }

啟動後，服務端正常列印結果：Hello action.
簡單梳理一下思路：
通過Netty傳遞，都需要基於流，以ChannelBuffer的形式傳遞。所以，Object -> ChannelBuffer.
Netty提供了轉換工具，需要我們配置到Handler。
樣例從客戶端 -> 服務端，單向發消息，所以在客戶端配置了編碼，服務端解碼。如果雙向收發，則需要全部配置Encoder和Decoder。
這里需要注意，注冊到Server的Handler是有順序的，如果你顛倒一下注冊順序：

bootstrap.setPipelineFactory(newChannelPipelineFactory() {
@Override publicChannelPipeline getPipeline()throwsException { returnChannels.pipeline(newObjectServerHandler(), newObjectDecoder(ClassResolvers.cacheDisabled(this .getClass().getClassLoader())) ); }});

結果就是，會先進入我們自己的業務，再進行解碼。這自然是不行的，會強轉失敗。至此，你應該會用Netty傳遞對象了吧。

『叄』 java開發聊天功能用什麼技術實現的

1. Socket編程：使用Socket可以在客戶端和伺服器之間建立TCP連接，實現雙方之間的實時通信。Java提供了Socket類和ServerSocket類，可用於實現Socket編程。
2. WebSocket：WebSocket是一種基於TCP協議的新型網路通信協議，它可以在瀏覽器和伺服器之間建立持久連接，實現雙向實時通信。Java可以使用一些WebSocket框架，如Netty、Tomcat等，來實現WebSocket功能。
3. HTTP長連接：HTTP長連接是通過保持TCP連接來實現通信的一種方式，可以在客戶端和伺服器之間建立持久連接，實現雙向實時通信。Java可以使用一些HTTP長連接框架，如Netty、Apache HttpClient等，來實現HTTP長連接功能。
4. 消息隊列：消息隊列可以實現非同步通信，通過在消息隊列中存儲消息，來實現客戶端和伺服器之間的實時通信。Java可以使用一些消息隊列框架，如ActiveMQ、RabbitMQ等，來實現消息隊列功能。
需要根據具體需求選擇合適的技術來實現聊天功能。