Comments (4)
I think so! Have a look at the OnProcessMessage
event hook.
https://github.com/mochi-co/mqtt/blob/master/server/events/events.go#L49
https://github.com/mochi-co/mqtt/blob/master/examples/events/main.go
And then you could do something like this...
server.Events.OnProcessMessage = func(cl events.Client, pk events.Packet) (pkx events.Packet, err error) {
// Check if pk.TopicName is 'someTopic'
pkx = pk
// Modify pkx.TopicName to new topic
return pkx, nil
}
I'm not sure how you could determine the wildcard domain for the client though. Open to throwing some ideas around. We expose the connecting client address in events.Client.Remote
if that's any use.
from server.
Thanks. Thinking about it properly though it would be better to not have a topic prefix but to have a whole seperate instance per sub-domain. So foo.myserver.com and bar.myserver.com are issolated and topic "someTopic" in one is not visible to the other. I guess that means a speperate instance of the Mochi MQTT server for each.
The way I have it presently uses the Go TLS Config GetConfigForClient
to get the client hello which has the server name the mqtt client is calling and so from that I can find the subdomain.
type Server struct {
. . .
mqttBroker *mqtt.Server
}
. . .
mqttTlsConfig := &tls.Config{
GetConfigForClient: s.getConfigForMqttClient,
}
s.mqttBroker = mqtt.NewServer(nil)
tcp := listeners.NewTCP("myMQTT", "localhost:8883")
err := s.mqttBroker.AddListener(tcp, &listeners.Config{
Auth: new(auth.Allow),
TLSConfig: mqttTlsConfig,
})
if err != nil {
log.Fatal(err)
}
go s.mqttBroker.Serve()
log.Println("MQTT Broker Started!")
. . .
func (s *Server) getConfigForMqttClient(hi *tls.ClientHelloInfo) (*tls.Config, error) {
log.Println("Server.getConfigForMqttClient hostName:", hi.ServerName)
ctx, err := s.GetContext(hi.ServerName)
if err != nil {
return nil, err
}
. . .
but i need some way for that to use multiple instances of Mochi mqtt.Server instead of just the one.
Probably too much for this Github issue and I need to work it out myself...
from server.
@torntrousers Very interested to hear updates if you made any progress on this.
from server.
We ended up implementing our own TLS listener which managed a collection of Mochi MQTT Servers and our listener called the Server EstablishConnection function on the appropriate Server. Seems to work ok.
from server.
Related Issues (20)
- After enabled badger, the vlog file up to 700M one day and 4GB one week HOT 9
- Race condition when running the redis example HOT 4
- 遍历Clients时如何判断当前Client是否为Disconected状态 HOT 3
- 作者您好,请帮忙关注一下这个问题 HOT 3
- Hi, what is the simplest way to make messages can be restored when server cut off? HOT 5
- [badgerdb] vlog growing unbounded - consider adding GC and exposing options HOT 6
- The badge still getting vlog file keep growing infirnity HOT 7
- How to send topics posted by specific users only to specific subscribed users? HOT 11
- Does peddle perssistant released? HOT 5
- MQTTX cannot use Topic Alias. MQTT5.0 主题别名发送卡住,无法发布主题别名的消息 HOT 2
- How to use the new pessistent hook? HOT 1
- Reload auth fIle on the run HOT 2
- InlineClient模式下服务端订阅问题,inline subscribers do not receive messages HOT 5
- Merge 2 version of storm HOT 4
- Add Support for Disconnect With Will Message Reason Code
- Logging Level is not Configurable Via File Configuration
- Persistence storage did not work with SetCleanSession(false) HOT 3
- Don't allow inheriting session unless username matches HOT 5
- MessageExpiry Hook HOT 4
- OnConnectAuthenticate cannot specify an error code (like Client Identifier not valid)
Recommend Projects
-
React
A declarative, efficient, and flexible JavaScript library for building user interfaces.
-
Vue.js
🖖 Vue.js is a progressive, incrementally-adoptable JavaScript framework for building UI on the web.
-
Typescript
TypeScript is a superset of JavaScript that compiles to clean JavaScript output.
-
TensorFlow
An Open Source Machine Learning Framework for Everyone
-
Django
The Web framework for perfectionists with deadlines.
-
Laravel
A PHP framework for web artisans
-
D3
Bring data to life with SVG, Canvas and HTML. 📊📈🎉
-
Recommend Topics
-
javascript
JavaScript (JS) is a lightweight interpreted programming language with first-class functions.
-
web
Some thing interesting about web. New door for the world.
-
server
A server is a program made to process requests and deliver data to clients.
-
Machine learning
Machine learning is a way of modeling and interpreting data that allows a piece of software to respond intelligently.
-
Visualization
Some thing interesting about visualization, use data art
-
Game
Some thing interesting about game, make everyone happy.
Recommend Org
-
Facebook
We are working to build community through open source technology. NB: members must have two-factor auth.
-
Microsoft
Open source projects and samples from Microsoft.
-
Google
Google ❤️ Open Source for everyone.
-
Alibaba
Alibaba Open Source for everyone
-
D3
Data-Driven Documents codes.
-
Tencent
China tencent open source team.
from server.