Comments (8)
@jlsan92 could you share example code with us? Do you have more than one type of responders, for example, with varying event handlers?
from cote.
My config is something like this:
1 Requester calling different functions on Responder
// app1.js
const { Requester } = require('cote');
const requester = new Requester({
name: 'Requester',
});
...
requester.send({ type, data }, res => console.log(res));
// app2.js
const { Responder } = require('cote');
const responder = new Responder({
name: 'Responder',
});
responder.on('functionlOne', ({ data }), cb => {
// do something
return cb();
});
responder.on('functionTwo', ({ data }), cb => {
// do something
return cb();
});
responder.on('functionThree', ({ data }), cb => {
// do something
return cb();
});
Only one "function" gets called, others never are executed.
I'm trying this on Docker, already tried Redis backend and still no luck.
from cote.
@jlsan92 it looks like it should work, except for the handler syntax, which is more like 'event', ({ data }, cb) => { })
.
It doesn't have anything to do with redis — if one works, the others should also work. Make sure you don't have other responders running on your machine at the same time, that have different message names than what are listed here.
If you can share a more realistic example that demonstrates the issue, I can also help debug it.
from cote.
I'm also have the same problem. The only first response of requests received. I use promises.
First service is responder of get methods of redis.
Second service is responder of set methods of redis.
Third service request get method, modified data and request to save to second service.
But only first call receive answer, does not matter what is it, set of get.
I tested this issue with another services (i.e. pm2 manager), and saw the same problem.
I'm also killall node
before each testing.
from cote.
I found a problem in balancer.
When I connect any other responder to the cluster, with another commands in respondsTo
option, a part of requests passed to it!
from cote.
@MaxSvargal so this is already documented behavior; and the explanation and the solution is as follows:
Note: By default, every Requester will connect to every Responder it discovers, regardless of the request type. This means, every Responder should respond to the exact same set of requests, because Requesters will load-balance requests between all connected Responders regardless of their capabilities, i.e, whether or not they can handle a given request.
If you have multiple Responders with varying response handlers, you will experience lost requests. In cote, this separation between responsibilities is called segmentation, or partitioning. If you wish to segment your requests in groups, you can use keys. Check out keys for a detailed guide on how and when to use segmentation.
https://github.com/dashersw/cote#keys
from cote.
@dashersw Ok, and how i can communicate with two responders with different keys from one requester? Or i need two instances of requester?
And why we need respondsTo
? Whats the point?
from cote.
i think like this :
var example1 = responder.on('functionlOne', ({ data }), cb => {
// do something
return cb();
});
var example2 = responder.on('functionTwo', ({ data }), cb => {
// do something
return cb();
});
var example3 = responder.on('functionThree', ({ data }), cb => {
// do something
return cb();
});
and call it the function
from cote.
Related Issues (20)
- No namespace and a strange "type" for Requester and Responder instances HOT 7
- Subscriber binding a socket instead of connecting (client vs server) ?
- Round-robin mechanism leads to lost requests HOT 4
- Client lost data when service graceful shutdown
- cote.js actively maintained? HOT 2
- Support specific ip addresses of instances. HOT 8
- Using cotejs on k3s cluster HOT 2
- K3S Kubernetes Cluster: TypeError [ERR_INVALID_ARG_TYPE]: The "options.port" property must be one of type number or string. Received null HOT 8
- Invalid 'main' field - node-discover HOT 2
- hiredis dependency preventing using node versions > 10? HOT 3
- [QUESTION] Are broadcasts mandatory? HOT 3
- Remove hiredis dependency HOT 2
- Discovery not working HOT 2
- How can I allow anyone over the Internet to run replicas of a service? HOT 1
- Cote not working with AWS Autoscalling instances. HOT 3
- Select port used
- Can't start cote due to port issue HOT 2
- View IP address of incoming request/broadcast HOT 1
- Hide "no listeners found for event" log HOT 2
- Requester can see the Responder but dont send request to it HOT 1
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 cote.