Java 服務(wù)端demo環(huán)境

• jdk1.8
• 框架:springboot+maven
• 開發(fā)工具:IDEA

在pom文件引入第三包封裝的netty框架maven坐標(biāo)

io.github.fzdwxsky-http-springboot-starter0.10.6

*注意:pom文件里需注釋掉springbootweb啟動器,web啟動器默認(rèn)是tomcat服務(wù)啟動,會和netty服務(wù)沖突

10年積累的成都網(wǎng)站建設(shè)、做網(wǎng)站經(jīng)驗(yàn)，可以快速應(yīng)對客戶對網(wǎng)站的新想法和需求。提供各種問題對應(yīng)的解決方案。讓選擇我們的客戶得到更好、更有力的網(wǎng)絡(luò)服務(wù)。我雖然不認(rèn)識你，你也不認(rèn)識我。但先網(wǎng)站設(shè)計(jì)后付款的網(wǎng)站建設(shè)流程，更有鎮(zhèn)江免費(fèi)網(wǎng)站建設(shè)讓你可以放心的選擇與我們合作。創(chuàng)建java服務(wù)端,以接口模式創(chuàng)建,方便外部調(diào)用

@GetMapping("/getConnect")
public void getConnect(HttpServerRequest request){request.upgradeToWebSocket(ws ->{ws.mountOpen(h->{   ws.send("連接成功,開始聊天吧!");
       });

     ws.mountText(s ->{ System.out.println(s);

             //對方回復(fù)
             System.out.println("客戶端回復(fù): "+s);

             //獲取控制臺輸入的值
             Scanner scanner =new Scanner(System.in);

             String next = scanner.next();

             ws.send(next);

     });

    });

}

啟動服務(wù),出現(xiàn)以下信息表示啟動成功,暴露端口默認(rèn):9999

接著把本地服務(wù)通過cpolar暴露到公網(wǎng),如需詳細(xì)了解cpolar安裝及使用,請參考如下文章:

遠(yuǎn)程公司內(nèi)網(wǎng)服務(wù)器【內(nèi)網(wǎng)穿透】

打開瀏覽器訪問:http://127.0.0.1:9200 cpolar web ui 界面,創(chuàng)建一個(gè)tcp 端口為9999的隧道

注意:該隧道選擇的是臨時(shí)tcp地址和端口,24小時(shí)內(nèi)會變化,如需固定tcp地址,可升級為專業(yè)套餐做tcp地址固定!

查看狀態(tài)->在線隧道,復(fù)制創(chuàng)建的隧道的公網(wǎng)地址加端口

此時(shí),websocket服務(wù)端已經(jīng)從本地localhost暴露至公網(wǎng),接著我們創(chuàng)建一個(gè)客戶端測試公網(wǎng)訪問socket服務(wù)端連接

以基于go的socket客戶端為例,通過公網(wǎng)連接java socket服務(wù)端

• go版本:1.19
• 開發(fā)工具:VSCODE

通過git下載websocket框架

go get github.com/gorilla/websocket

創(chuàng)建GO客戶端, 注意:Host值為上面復(fù)制的隧道公網(wǎng)地址!!

package main

import (
    "fmt"
    "log"
    "net/url"

    "github.com/gorilla/websocket"
)

func main() {// 定義服務(wù)端的地址

    u := url.URL{Scheme: "ws",
        Host:   "3.tcp.vip.cpolar.cn:10793", //地址為復(fù)制隧道的公網(wǎng)地址
        Path:   "/eth/getConnect"} //服務(wù)端controller 映射地址

    // 與服務(wù)端建立連接
    c, _, err := websocket.DefaultDialer.Dial(u.String(), nil)
    if err != nil {log.Fatal("dial:", err)
    }
    defer c.Close()

    // 阻塞主線程
    down := make(chan byte)

    // 啟動一個(gè)線程，讀取從服務(wù)端發(fā)送過來的數(shù)據(jù)
    go func() {for {_, message, _ := c.ReadMessage()
            fmt.Println("服務(wù)端回復(fù):" + string(message))
        }
    }()

    //啟動一個(gè)線程輸入消息
    go func() {for {var input string

            fmt.Scanln(&input)

            c.WriteMessage(websocket.TextMessage, []byte(input))

        }

    }()

    for {<-down
    }
}

接著啟動服務(wù),與服務(wù)端連接,出現(xiàn)服務(wù)端返回的字樣表示連接成功

客戶端在控制臺輸入信息,點(diǎn)擊回車

服務(wù)端接收到且打印出現(xiàn)客戶端發(fā)送的信息

接著在服務(wù)端控制臺輸入消息,按回車客戶端收到服務(wù)端回復(fù)的消息,連接成功

你是否還在尋找穩(wěn)定的海外服務(wù)器提供商？創(chuàng)新互聯(lián)www.cdcxhl.cn海外機(jī)房具備T級流量清洗系統(tǒng)配攻擊溯源，準(zhǔn)確流量調(diào)度確保服務(wù)器高可用性，企業(yè)級服務(wù)器適合批量采購，新人活動首月15元起，快前往官網(wǎng)查看詳情吧

分享題目：java本地socket服務(wù)端暴露至公網(wǎng)訪問【內(nèi)網(wǎng)穿透】-創(chuàng)新互聯(lián)
文章網(wǎng)址：http://weahome.cn/article/esgge.html