2. 程式人生 > >使用最新Netty實現一個簡單的聊天程式

使用最新Netty實現一個簡單的聊天程式

阿新 • • 發佈：2019-02-15

1、概述

    Netty是由JBOSS提供的一個java開源框架。Netty提供非同步的、事件驅動的網路應用程式框架和工具，用以快速開發高效能、高可靠性的網路伺服器和客戶端程式。

    目前最新的是版本是4.1.4（5.x版本官網已經棄用，不推薦使用）。

    Netty4.x同時也是原生支援Android的，所以後面的程式，放到android上也是可以正常執行的（親測）。

    專案如果使用Maven開發，直接新增以下依賴即可：

  1. <dependency>
  2. <groupId>io.netty</groupId>
  3. <artifactId>
     
    netty-all</artifactId>
  4. <version>4.1.4.Final</version>
  5. </dependency>

2、實現服務端

    首先是訊息處理類ServerHandler：

  1. package com.anxpp.im.server.handler;
  2. import io.netty.channel.ChannelHandler;
  3. import io.netty.channel.ChannelHandlerContext;
  4. import io.netty.channel.ChannelInboundHandlerAdapter
     
    ;
  5. import java.io.IOException;
  6. import com.anxpp.im.common.IMMessage;
  7. import com.anxpp.im.common.OnlineUser;
  8. import com.anxpp.im.server.config.BaseConfig;
  9. @ChannelHandler.Sharable
  10. publicclassServerHandlerextendsChannelInboundHandlerAdapterimplementsBaseConfig{
  11. privateChannelHandlerContext ctx;
  12. @Override
  13. public
     
    void handlerAdded(ChannelHandlerContext ctx)throwsException{
  14. System.err.println("服務端Handler建立...");
  15. super.handlerAdded(ctx);
  16. }
  17. @Override
  18. publicvoid channelInactive(ChannelHandlerContext ctx)throwsException{
  19. System.err.println("channelInactive");
  20. super.channelInactive(ctx);
  21. }
  22. /**
  23.      * tcp鏈路建立成功後呼叫
  24.      */
  25. @Override
  26. publicvoid channelActive(ChannelHandlerContext ctx)throwsException{
  27. this.ctx = ctx;
  28. System.err.println("有客戶端連線："+ctx.channel().remoteAddress().toString());
  29. }
  30. /**
  31.      * 傳送訊息
  32.      */
  33. publicboolean sendMsg(IMMessage msg)throwsIOException{
  34. System.err.println("伺服器推送訊息:"+msg);
  35.         ctx.writeAndFlush(msg);
  36. return msg.getMsg().equals("q")?false:true;
  37. }
  38. @Override
  39. publicvoid channelRead(ChannelHandlerContext ctx,Object msg)throwsIOException{
  40. System.err.println("伺服器接收到訊息:"+msg);
  41. IMMessage message =(IMMessage)msg;
  42. if(OnlineUser.get(message.getReceiveId())==null){
  43. OnlineUser.put(message.getUid(), ctx);
  44. }
  45. ChannelHandlerContext c =OnlineUser.get(message.getReceiveId());
  46. if(c==null){
  47.             message.setMsg("對方不線上！");
  48. OnlineUser.get(message.getUid()).writeAndFlush(message);
  49. }
  50. else
  51.             c.writeAndFlush(message);
  52. }
  53. /**
  54.      * 異常處理
  55.      */
  56. @Override
  57. publicvoid exceptionCaught(ChannelHandlerContext ctx,Throwable cause){
  58. System.err.println("與客戶端斷開連線:"+cause.getMessage());
  59.         cause.printStackTrace();
  60.         ctx.close();
  61. }
  62. }

    接收客戶端連線，如果客戶端沒有連線過，就儲存ChannelHandlerContext到Map中用於傳送訊息。然後判斷訊息接收方是否線上，若線上就直接傳送訊息，沒有線上就返回“對方不線上”。當然，可以將訊息傳送者和訊息接收者ID設定為相同就能僅開一個客戶端自己跟自己聊天（類似Echo Server）。

    伺服器程式Server：

  1. package com.anxpp.im.server;
  2. import io.netty.bootstrap.ServerBootstrap;
  3. import io.netty.channel.ChannelFuture;
  4. import io.netty.channel.ChannelInitializer;
  5. import io.netty.channel.ChannelOption;
  6. import io.netty.channel.EventLoopGroup;
  7. import io.netty.channel.nio.NioEventLoopGroup;
  8. import io.netty.channel.socket.SocketChannel;
  9. import io.netty.channel.socket.nio.NioServerSocketChannel;
  10. import io.netty.handler.codec.LengthFieldBasedFrameDecoder;
  11. import io.netty.handler.codec.LengthFieldPrepender;
  12. import java.io.IOException;
  13. import java.util.Scanner;
  14. import com.anxpp.im.common.IMMessage;
  15. import com.anxpp.im.common.MsgPackDecode;
  16. import com.anxpp.im.common.MsgPackEncode;
  17. import com.anxpp.im.server.config.BaseConfig;
  18. import com.anxpp.im.server.handler.ServerHandler;
  19. publicclassServerimplementsRunnable,BaseConfig{
  20. ServerHandler serverHandler =newServerHandler();
  21. publicstaticvoid main(String[] args)throwsIOException{
  22. newServer().start();
  23. }
  24. publicvoid start()throwsIOException{
  25. newThread(this).start();
  26.         runServerCMD();
  27. }
  28. /**啟動服務端控制檯
  29.      * @throws IOException */
  30. privatevoid runServerCMD()throwsIOException{
  31. //服務端主動推送訊息
  32. int toID =1;
  33. IMMessage message =newIMMessage(
  34.                 APP_IM,
  35.                 CLIENT_VERSION,
  36.                 SERVER_ID,
  37.                 TYPE_MSG_TEXT,
  38.                 toID,
  39.                 MSG_EMPTY);
  40. @SuppressWarnings("resource")
  41. Scanner scanner =newScanner(System.in);
  42. do{
  43.             message.setMsg(scanner.nextLine());
  44. }
  45. while(serverHandler.sendMsg(message));
  46. }
  47. publicvoid run(){
  48. EventLoopGroup bossGroup =newNioEventLoopGroup();
  49. EventLoopGroup workerGroup =newNioEventLoopGroup();
  50. try{
  51. ServerBootstrap b =newServerBootstrap();
  52.             b.group(bossGroup, workerGroup).channel(NioServerSocketChannel.class).option(ChannelOption.SO_BACKLOG,1024)
  53. //                  .childOption(ChannelOption.SO_KEEPALIVE, true)
  54. .childHandler( 
 
    
            
      
    
           
    
              
              
    
            
    
            
    相關推薦
    
			   
            
            
            
 

    

    
    
    
    使用最新Netty實現一個簡單的聊天程式
    
     
     
                


1、概述

    Netty是由JBOSS提供的一個java開源框架。Netty提供非同步的、事件驅動的網路應用程式框架和工具，用以快速開發高效能、高可靠性的網路伺服器和客戶端程式。


    目前最新的是版本是4.1.4（5.x版本官網已經棄用，不 
    

    
  
 

    

    
    
    
    自己用-Netty-實現一個簡單的-RPC
    
     
       
轉自：http://thinkinjava.cn/2018/03/%E8%87%AA%E5%B7%B1%E7%94%A8-Netty-%E5%AE%9E%E7%8E%B0%E4%B8%80%E4%B8%AA%E7%AE%80%E5%8D%95%E7%9A%84-RPC/ 
目錄： 
 
 需求 
    

    
  
 

    

    
    
    
    Swing 實現一個簡單窗體程式，並打成可執行jar包
    
     
     
							
							
							1. 前言

在做App自動化測試時，需要經常獲取裝置資訊，Apk的包名，啟動activity等，每次都用命令列獲取很是麻煩，於是想到做一個窗體程式，只需要點幾個按鈕，就可以獲得所需資訊。最終介面如下： 




2.佈局思路

這裡不對窗體具體功能做介紹，說一 
    

    
  
 

    

    
    
    
    網路程式設計與多執行緒的應用--基於socket udp編寫一個簡單聊天程式
    
     
     void CChatDlg::OnBnClickedButtonSend()
{// TODO: Add your control notification handler code here//獲取對方IPCIPAddressCtrl* pIPAddress = ((CIPAddressCtrl*)GetD 
    

    
  
 

    

    
    
    
    netty實現一個簡單的服務端和客戶端通訊
    
     
     
                netty java Nio網路通訊框架，能接收TCP，http，webSocket，UDPelk包括：logStash，Elasticsearch，KibanaLogStash：tcp監聽netty伺服器傳送的資訊，並把訊息處理好後轉發給ESElasticsearch：接受 
    

    
  
 

    

    
    
    
    Netty學習——用Netty實現一個簡單的Http伺服器
    
     
     package study.netty;

import io.netty.bootstrap.ServerBootstrap;
import io.netty.buffer.ByteBuf;
import io.netty.buffer.Unpooled;
import io.netty.channel.C 
    

    
  
 

    

    
    
    
    使用ASP.NET SignalR實現一個簡單的聊天室
    
     
     spl   記錄   歷史   undefine   reat   語句   關鍵字   pda   name   　前言
　　距離我寫上一篇博客已經又過了一年半載了，時間過得很快，一眨眼，就把人變得滄桑了許多。青春是短暫的，知識是無限的。要用短暫的青春，去學無窮無盡的知識，及時當勉勵，歲月不待人。今天寫個隨 
    

    
  
 

    

    
    
    
    TCP實現簡單聊天程式
    
     
      
 
 
   上次我們通過UDP來實現了簡單的聊天程式，這次我們用TCP協議來實現，TCP和UDP不同的是TCP需要建立連線。 
 //這是一個通過TCP協議來實現聊天的程式
//1.建立socket
//2.為socket繫結地址
//3.向服務端傳送連結請求
//4.傳送資料
// 
    

    
  
 

    

    
    
    
    利用訊息佇列實現簡單聊天程式
    
     
      
  
  
 本篇利用訊息佇列的特性實現簡單的聊天程式，msgsnd傳送資料，msgrcv接收資料來實現聊天功能，訊息佇列詳情。 資料接收端msgrcv 
 //這是一個以system V訊息佇列實現的聊天程式客戶端
////  1.建立訊息佇列
////  2.從訊息佇列中獲取一個數據，打印出來
/// 
    

    
  
 

    

    
    
    
    python實現一個簡單的ftp程式
    
     
      
 
 客戶端可以向伺服器端下載，上傳檔案 
 下載檔案指令：get_filename 
 上傳檔案指令：put_filename 
 ftp工程目錄： 
  
 ftp工作原理： 
 put指令工作原理圖： 
  
 put指令工作原理圖： 
   
  
 程式碼： 
 客戶端： 
 impo 
    

    
  
 

    

    
    
    
    Socket程式設計-TCP實現簡單聊天程式
    
     
      
 
 
 在System.net.Sockets的名稱空間中，TcpListener類與TcpClient類是兩個專門用於TCP協議程式設計的類，它們封裝了底層的套接字並分別提供了用Socket進行同步和非同步通訊的方法，降低了TCP應用程式設計的難度。 
 在網路應用程式設計中，利用TCP協議編寫的程式 
    

    
  
 

    

    
    
    
    Netty+Websocket 實現一個簡易聊天室
    
     
      
 
 後臺程式碼 
 /**
 * 服務端
 */
public class ChatServer {

	public static void main(String[] args) throws Exception {
		int port=8080; //服務端預設埠
		new Ch 
    

    
  
 

    

    
    
    
    【MATLAB】一個簡單的程式實現細胞計數
    
     
     
                ##實現帶UI介面的程式，對細胞計數

首先在建立一個圖形使用者介面，副檔名為.fIg的檔案，在MATlAB命令視窗啟動GUIDE，進行佈局，大致佈局為自己想要的介面，下圖是我自己做的介面（圖一)。可以選中屬性進行編輯 

圖一圖二右鍵按鈕進入編輯器，即按鈕1的回撥函式，在函 
    

    
  
 

    

    
    
    
    使用netty實現一個多人聊天室--failed: Error during WebSocket handshake: Unexpected response code: 200
    
     
      
 
  
  
 
 
  初次接觸netty , 本文主要內容如下:
  
   
    遇到的小bug
    聊天室後端程式碼：
    聊天室前端程式碼：
   
  
 
  
 遇到的小bug 
 在使用netty進行websocket程式設計（實現一個簡單的聊天室）時，我遇到了這樣一個奇怪 
    

    
  
 

    

    
    
    
    一個基於python3+PyQt5實現的簡單計算器程式
    
     
     
                
【開發平臺】ubuntu14 + python3 + PyQt5
【執行介面】



【原始碼】

# -*- coding: utf-8 -*-

'''
Description: A simple calculater based on PyQt5
Author: wa 
    

    
  
 

    

    
    
    
    一個簡單聊天介面的UI實現
    
     
     
                
能力是在不斷學習和實踐中提升的，閒來沒事，就寫了這個簡單的聊天介面，沒有什麼難點，但絕對實用。下面請看介面顯示：
其實，這個介面的實現是很簡單的，就是一個ListView的應用，話不多說，直接貼程式碼了，首先是MainActivity
public class MainAc 
    

    
  
 

    

    
    
    
    如何用WebSocket實現一個簡單的聊天室以及單聊功能
    
     
     百度百科中這樣定義WebSocket:WebSocket協議是基於TCP的一種新的網路協議。它實現了瀏覽器與伺服器全雙工(full-duplex)通訊——允許伺服器主動傳送資訊給客戶端。簡單的說，WebSocket協議之前，雙工通訊是通過多個http連結來實現，這導致了效率低下,而WebSocket解決了這個 
    

    
  
 

    

    
    
    
    python實現簡單聊天程式
    
     
     
								
								            
							
							
							客戶端

#coding:utf-8
import socket, sys

host = 'localhost'
port = 10001

s = socket.socket(socket.AF_I 
    

    
  
 

    

    
    
    
    實現一個簡單的語音聊天室（原始碼）
    
     
     
    public partial class SpeakerPanel : UserControl ,IDisposable
    {
        private ChatUnit chatUnit;     

        public SpeakerPanel()
       
    

    
  
 

    

    
    
    
    實現一個簡單的視訊聊天室（原始碼）
    
     
            在 《》一文釋出後，很多朋友建議我也實現一個視訊聊天室給他們參考一下，其實，視訊聊天室與語音聊天室的原理是差不多的，由於加入了攝像頭、視訊的處理，邏輯會繁雜一些，本文就實現一個簡單的多人視訊聊天系統，讓多個人可以進入同一個房間進行語音視訊溝通。先看看3個人進行視訊聊天的執行效果截圖：