-
client: private void start() { BufferedReader inputReader = null; Socket socket = null; BufferedWriter writer = null; try { socket=new Socket("localhost",6898); inputReader=new BufferedReader(new InputStreamReader(System.in)); writer=new BufferedWriter(new OutputStreamWriter(socket.getOutputStream())); String inputContent; while(!(inputContent=inputReader.readLine()).equals("bye")){ writer.write(inputContent+"\n");//一定要加\n writer.flush(); } } catch (IOException e) { e.printStackTrace(); }finally{ try { inputReader.close(); socket.close(); writer.close(); } catch (IOException e) { e.printStackTrace(); } } } }查看全部
-
socketServer.java: public class SocketServer { /** * @param args */ public static void main(String[] args) { SocketServer socketServer=new SocketServer(); socketServer.startServer(); } public void startServer() { ServerSocket serverSocket; BufferedReader reader; try { serverSocket=new ServerSocket(6898); Socket socket = serverSocket.accept(); reader=new BufferedReader(new InputStreamReader(socket.getInputStream())); String receiveMsg; while((receiveMsg=reader.readLine())!=null){ System.out.println(receiveMsg); } } catch (Exception e) { e.printStackTrace(); } } }查看全部
-
socketClient.java: public class SocketClient { /** * @param args */ public static void main(String[] args) { SocketClient client =new SocketClient(); client.start(); } private void start() { BufferedReader inputReader; inputReader=new BufferedReader(new InputStreamReader(System.in)); String inputContent; try { while(!(inputContent=inputReader.readLine()).equals("bye")){ System.out.println(inputContent); } } catch (IOException e) { e.printStackTrace(); } } }查看全部
-
客户端使用Mina查看全部
-
客户端Mina的使用查看全部
-
長連接和短連接查看全部
-
服务器端: ServerSocket ss = new ServerSocket(9809); ...等待客户端请求连接 Socket sk = ss.accept; ...客户端连接 客户端: Socket sk = new Socket("127.0.0.1" ,9809); ....连接建立,可以通过socket通信查看全部
-
mina:查看全部
-
decode:查看全部
-
encode:查看全部
-
客户端 Socket socket = new Socket("127.0.0.1",9898); BufferWriter writer = new BufferWriter(new OutputStreamReader(socket.getOutputStream)); ... writer.write("content..."); writer.flush();查看全部
-
ServerSocket severSocket = new ServerSocket(9898); Socket socket = severSocket.accept(); BufferReader read = new BufferReader(new InputStreamReader(socket.getInputStream()));查看全部
-
1、并发量 2、服务器与客户端的身份鉴别 3、断线重连查看全部
-
实现即时通讯有俩种 1.长连接。原理推送 2.短连接。原理轮询查看全部
-
定时任务查看全部
举报
0/150
提交
取消